secstate/Notify
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

cleanups

Browse Source
This commit is contained in:
ranfdev
2023-11-09 19:10:27 +01:00
parent 6581eb55ab
commit 20ee796913
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/application.rs
View File

@ -281,10 +281,9 @@ impl NotifyApplication {
impl models::NetworkMonitorProxy for Proxies { impl models::NetworkMonitorProxy for Proxies {
fn listen(&self) -> Pin<Box<dyn Stream<Item = ()>>> { fn listen(&self) -> Pin<Box<dyn Stream<Item = ()>>> {
let (tx, rx) = async_channel::bounded(1); let (tx, rx) = async_channel::bounded(1);
let mut prev_available = Rc::new(Cell::new(false)); let prev_available = Rc::new(Cell::new(false));
gio::NetworkMonitor::default().connect_network_changed(move |_, available| { gio::NetworkMonitor::default().connect_network_changed(move |_, available| {
dbg!("sent", available);
if available && !prev_available.get() { if available && !prev_available.get() {
if let Err(e) = tx.send_blocking(()) { if let Err(e) = tx.send_blocking(()) {
warn!(error = %e); warn!(error = %e);