monoio/io/stream/
iter.rs

1use super::{assert_stream, Stream};
2
3/// Stream for the [`iter`] function.
4#[derive(Debug, Clone)]
5#[must_use = "streams do nothing unless polled"]
6pub struct Iter<I> {
7    iter: I,
8}
9
10/// Converts an `Iterator` into a `Stream` which is always ready
11/// to yield the next value.
12pub fn iter<I>(i: I) -> Iter<I::IntoIter>
13where
14    I: IntoIterator,
15{
16    assert_stream::<I::Item, _>(Iter {
17        iter: i.into_iter(),
18    })
19}
20
21impl<I> Stream for Iter<I>
22where
23    I: Iterator,
24{
25    type Item = I::Item;
26
27    async fn next(&mut self) -> Option<Self::Item> {
28        self.iter.next()
29    }
30
31    fn size_hint(&self) -> (usize, Option<usize>) {
32        self.iter.size_hint()
33    }
34}