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

pub fn iter_ok<I, E>(i: I) -> IterOk<<I as IntoIterator>::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::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()));