5 files changed, 6 insertions, 6 deletions
diff --git a/tokio/tests/fs_dir.rs b/tokio/tests/fs_dir.rs
index c8b32fc6..eaff59da 100644
--- a/tokio/tests/fs_dir.rs
+++ b/tokio/tests/fs_dir.rs
@@ -71,7 +71,7 @@ async fn read_inherent() {
 
 #[tokio::test]
 async fn read_stream() {
-    use futures::StreamExt;
+    use tokio::stream::StreamExt;
 
     let base_dir = tempdir().unwrap();
 
diff --git a/tokio/tests/io_lines.rs b/tokio/tests/io_lines.rs
index 3775cae0..2f6b3393 100644
--- a/tokio/tests/io_lines.rs
+++ b/tokio/tests/io_lines.rs
@@ -20,7 +20,7 @@ async fn lines_inherent() {
 
 #[tokio::test]
 async fn lines_stream() {
-    use futures::StreamExt;
+    use tokio::stream::StreamExt;
 
     let rd: &[u8] = b"hello\r\nworld\n\n";
     let mut st = rd.lines();
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>();
 
diff --git a/tokio/tests/sync_watch.rs b/tokio/tests/sync_watch.rs
index 409615d4..2bc5bb2a 100644
--- a/tokio/tests/sync_watch.rs
+++ b/tokio/tests/sync_watch.rs
@@ -195,7 +195,7 @@ fn poll_close() {
 
 #[test]
 fn stream_impl() {
-    use futures::StreamExt;
+    use tokio::stream::StreamExt;
 
     let (tx, mut rx) = watch::channel("one");
 
diff --git a/tokio/tests/time_interval.rs b/tokio/tests/time_interval.rs
index 6a1c756f..1123681f 100644
--- a/tokio/tests/time_interval.rs
+++ b/tokio/tests/time_interval.rs
@@ -45,7 +45,7 @@ async fn usage() {
 
 #[tokio::test]
 async fn usage_stream() {
-    use futures::StreamExt;
+    use tokio::stream::StreamExt;
 
     let start = Instant::now();
     let mut interval = time::interval(ms(10));