pub fn iter_ok<I, E>(i: I) -> IterOk<I::IntoIter, E> where
I: IntoIterator,
Expand description
Converts an Iterator
into a Stream
which is always ready
to yield the next value.
Iterators in Rust don’t express the ability to block, so this adapter
simply always calls iter.next()
and returns that.
use futures::*;
let mut stream = stream::iter_ok::<_, ()>(vec![17, 19]);
assert_eq!(Ok(Async::Ready(Some(17))), stream.poll());
assert_eq!(Ok(Async::Ready(Some(19))), stream.poll());
assert_eq!(Ok(Async::Ready(None)), stream.poll());