Function futures::stream::iter_ok [] [src]

pub fn iter_ok<I, E>(i: I) -> IterOk<I::IntoIter, E> where
    I: IntoIterator

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 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());