diff options
Diffstat (limited to 'tokio/tests/sync_mpsc.rs')
-rw-r--r-- | tokio/tests/sync_mpsc.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/tokio/tests/sync_mpsc.rs b/tokio/tests/sync_mpsc.rs index e1f99595..7e5c60e2 100644 --- a/tokio/tests/sync_mpsc.rs +++ b/tokio/tests/sync_mpsc.rs @@ -42,7 +42,7 @@ fn send_recv_with_buffer() { #[tokio::test] async fn send_recv_stream_with_buffer() { - use futures::StreamExt; + use tokio::stream::StreamExt; let (mut tx, mut rx) = mpsc::channel::<i32>(16); @@ -147,7 +147,7 @@ async fn async_send_recv_unbounded() { #[tokio::test] async fn send_recv_stream_unbounded() { - use futures::StreamExt; + use tokio::stream::StreamExt; let (tx, mut rx) = mpsc::unbounded_channel::<i32>(); |