summaryrefslogtreecommitdiffstats
path: root/tokio-futures/src/stream/mod.rs
diff options
context:
space:
mode:
Diffstat (limited to 'tokio-futures/src/stream/mod.rs')
-rw-r--r--tokio-futures/src/stream/mod.rs38
1 files changed, 0 insertions, 38 deletions
diff --git a/tokio-futures/src/stream/mod.rs b/tokio-futures/src/stream/mod.rs
deleted file mode 100644
index a6d987d6..00000000
--- a/tokio-futures/src/stream/mod.rs
+++ /dev/null
@@ -1,38 +0,0 @@
-//! Use streams with `async` / `await`.
-
-mod next;
-
-pub use self::next::Next;
-
-use futures::Stream;
-
-/// An extension trait which adds utility methods to `Stream` types.
-pub trait StreamExt: Stream {
- /// Creates a future that resolves to the next item in the stream.
- ///
- /// # Examples
- ///
- /// ```edition2018
- /// #![feature(async_await)]
- /// tokio::run_async(async {
- /// // The extension trait can also be imported with
- /// // `use tokio::prelude::*`.
- /// use tokio::prelude::{stream, StreamAsyncExt};
- ///
- /// let mut stream = stream::iter_ok::<_, ()>(1..3);
- ///
- /// assert_eq!(stream.next().await, Some(Ok(1)));
- /// assert_eq!(stream.next().await, Some(Ok(2)));
- /// assert_eq!(stream.next().await, Some(Ok(3)));
- /// assert_eq!(stream.next().await, None);
- /// });
- /// ```
- fn next(&mut self) -> Next<'_, Self>
- where
- Self: Sized + Unpin,
- {
- Next::new(self)
- }
-}
-
-impl<T: Stream> StreamExt for T {}