diff options
| -rw-r--r-- | tokio/src/stream/mod.rs | 12 |
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>), |