Add IntoStream for all Iterator<_>iter-into-stream

Signed-off-by: Matthias Beyer <mail@beyermatthias.de>

1 files changed, 12 insertions, 0 deletions

diff --git a/tokio/src/stream/mod.rs b/tokio/src/stream/mod.rs
index 6bf42324..f14e59f8 100644
--- a/tokio/src/stream/mod.rs
+++ b/tokio/src/stream/mod.rs
@@ -926,6 +926,18 @@ pub trait StreamExt: Stream {
 
 impl<St: ?Sized> StreamExt for St where St: Stream {}
 
+pub trait IntoStream<T>: std::iter::Iterator<Item = T> + Sized {
+    fn into_stream(self) -> Iter<Self>;
+}
+
+impl<I, T> IntoStream<T> for I
+    where I: std::iter::Iterator<Item = T> + Sized
+{
+    fn into_stream(self) -> Iter<Self> {
+        iter(self)
+    }
+}
+
 /// Merge the size hints from two streams.
 fn merge_size_hints(
     (left_low, left_high): (usize, Option<usize>),