pub fn iter_ok<I, E>(i: I) -> IterOk<<I as IntoIterator>::IntoIter, E> where
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::prelude::*; use futures::stream; use futures_executor::block_on; let mut stream = stream::iter_ok::<_, ()>(vec![17, 19]); assert_eq!(Ok(vec![17, 19]), block_on(stream.collect()));