more

zeromq · Dec 13, 2024 · fad6225 · fad6225
1 parent 2551442
commit fad6225
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 7 deletions.
diff --git a/src/transport/mod.rs b/src/transport/mod.rs
@@ -104,9 +104,9 @@ where
 #[cfg(any(feature = "async-std-runtime", feature = "async-dispatcher-runtime"))]
 fn make_framed<T>(stream: T) -> FramedIo
 where
-    T: futures_io::AsyncRead + futures_io::AsyncWrite + Send + Sync + 'static,
+    T: futures::AsyncRead + futures::AsyncWrite + Send + Sync + 'static,
 {
-    use futures_util::AsyncReadExt;
+    use futures::AsyncReadExt;
     let (read, write) = stream.split();
     FramedIo::new(Box::new(read), Box::new(write))
 }
diff --git a/tests/pub_sub.rs b/tests/pub_sub.rs
@@ -5,8 +5,8 @@ mod test {
     use zeromq::ZmqMessage;
     use zeromq::__async_rt as async_rt;
 
-    use futures_channel::{mpsc, oneshot};
-    use futures_util::{SinkExt, StreamExt};
+    use futures::channel::{mpsc, oneshot};
+    use futures::{SinkExt, StreamExt};
     use std::time::Duration;
 
     #[async_rt::test]
@@ -102,6 +102,6 @@ mod test {
             "ipc://asdf.sock",
             "ipc://anothersocket-asdf",
         ];
-        futures_util::future::join_all(addrs.into_iter().map(helper)).await;
+        futures::future::join_all(addrs.into_iter().map(helper)).await;
     }
 }
diff --git a/tests/req_rep.rs b/tests/req_rep.rs
@@ -3,7 +3,7 @@ mod helpers;
 use zeromq::__async_rt as async_rt;
 use zeromq::prelude::*;
 
-use futures_util::StreamExt;
+use futures::StreamExt;
 use std::error::Error;
 use std::time::Duration;
 

diff --git a/tests/req_router_dealer_rep.rs b/tests/req_router_dealer_rep.rs
@@ -7,7 +7,7 @@ mod test {
     use zeromq::__async_rt as async_rt;
     use zeromq::prelude::*;
 
-    use futures_util::StreamExt;
+    use futures::StreamExt;
     use std::error::Error;
     use std::time::Duration;