No need to spawn another task, this is a spawned task anyways.

This commit is contained in:
Lucy 2022-02-07 16:25:55 -05:00
parent 94dc038e2b
commit 833219d27a
No known key found for this signature in database
GPG key ID: EBC517FAD666BBF1

View file

@ -54,18 +54,13 @@ async fn get_wifi_mode(tx: Sender<bool>) -> zbus::Result<()> {
let wireless_enabled = network_manager.wireless_enabled().await?;
tx.send(wireless_enabled)
.expect("Failed to send wifi enablement back to main thread");
tokio::spawn(async move {
let connection = Connection::system().await?;
let network_manager = NetworkManager::new(&connection).await?;
let mut stream = network_manager.receive_wireless_enabled_changed().await;
while let Some(wireless_enabled) = stream.next().await {
if let Ok(wireless_enabled) = wireless_enabled.get().await {
tx.send(wireless_enabled)
.expect("Failed to send wifi enablement back to main thread");
}
let mut stream = network_manager.receive_wireless_enabled_changed().await;
while let Some(wireless_enabled) = stream.next().await {
if let Ok(wireless_enabled) = wireless_enabled.get().await {
tx.send(wireless_enabled)
.expect("Failed to send wifi enablement back to main thread");
}
zbus::Result::Ok(())
});
}
Ok(())
}