Make it send.

dvc94ch · Nov 11, 2020 · 230effb · 230effb
1 parent a51fad8
commit 230effb
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 2 deletions.
diff --git a/src/lib.rs b/src/lib.rs
@@ -94,4 +94,14 @@ mod tests {
             .await;
         });
     }
+
+    #[test]
+    fn test_is_send() {
+        futures_lite::future::block_on(async {
+            fn is_send<T: Send>(_: T) {}
+            is_send(AddrSet::new());
+            is_send(AddrSet::new().await.unwrap());
+            is_send(AddrSet::new().await.unwrap().next());
+        });
+    }
 }
diff --git a/src/windows.rs b/src/windows.rs
@@ -88,7 +88,7 @@ struct RouteChangeNotification {
 }
 
 /// The type of route change callbacks
-type RouteChangeCallback = Box<dyn FnMut(&MIB_IPINTERFACE_ROW, MIB_NOTIFICATION_TYPE) + Send>;
+type RouteChangeCallback = Box<dyn Fn(&MIB_IPINTERFACE_ROW, MIB_NOTIFICATION_TYPE) + Send>;
 impl RouteChangeNotification {
     /// Register for route change notifications
     fn new(cb: RouteChangeCallback) -> std::io::Result<Self> {
@@ -98,7 +98,7 @@ impl RouteChangeNotification {
             Row: *mut MIB_IPINTERFACE_ROW,
             NotificationType: MIB_NOTIFICATION_TYPE,
         ) {
-            (**(CallerContext as *mut RouteChangeCallback))(&*Row, NotificationType)
+            (**(CallerContext as *const RouteChangeCallback))(&*Row, NotificationType)
         }
         let mut handle = core::ptr::null_mut();
         let callback = Box::into_raw(Box::new(cb));
@@ -128,6 +128,8 @@ impl Drop for RouteChangeNotification {
     }
 }
 
+unsafe impl Send for RouteChangeNotification {}
+
 #[cfg(test)]
 mod tests {
     use super::*;