diff --git a/Cargo.lock b/Cargo.lock index e77b01e..31aad13 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -1152,9 +1152,9 @@ dependencies = [ [[package]] name = "n0-watcher" -version = "0.2.0" +version = "0.3.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "f216d4ebc5fcf9548244803cbb93f488a2ae160feba3706cd17040d69cf7a368" +checksum = "c31462392a10d5ada4b945e840cbec2d5f3fee752b96c4b33eb41414d8f45c2a" dependencies = [ "derive_more 1.0.0", "n0-future", diff --git a/netwatch/Cargo.toml b/netwatch/Cargo.toml index 7920ca5..a321c57 100644 --- a/netwatch/Cargo.toml +++ b/netwatch/Cargo.toml @@ -19,7 +19,7 @@ workspace = true atomic-waker = "1.1.2" bytes = "1.7" n0-future = "0.1.3" -n0-watcher = "0.2" +n0-watcher = "0.3" nested_enum_utils = "0.2.0" pin-project-lite = "0.2.16" snafu = "0.8.5" diff --git a/netwatch/src/netmon.rs b/netwatch/src/netmon.rs index 9354662..772c7bc 100644 --- a/netwatch/src/netmon.rs +++ b/netwatch/src/netmon.rs @@ -101,9 +101,9 @@ mod tests { #[tokio::test] async fn test_smoke_monitor() { let mon = Monitor::new().await.unwrap(); - let sub = mon.interface_state(); + let mut sub = mon.interface_state(); - let current = sub.get().unwrap(); + let current = sub.get(); println!("current state: {current}"); } } diff --git a/netwatch/tests/smoke.rs b/netwatch/tests/smoke.rs index 4dce37b..6bf15dc 100644 --- a/netwatch/tests/smoke.rs +++ b/netwatch/tests/smoke.rs @@ -31,9 +31,9 @@ async fn smoke_test() -> TestResult { // so this is more of a test to see if we gracefully handle these situations & if our // .wasm files are without "env" imports. tracing::info!("subscribing to netmon"); - let sub = monitor.interface_state(); + let mut sub = monitor.interface_state(); - let current = sub.get()?; + let current = sub.get(); tracing::info!(?current, "network change"); tracing::info!("successfully subscribed to netmon");