Function futures::stream::once [−] [src]

pub fn once<T, E>(item: Result<T, E>) -> Once<T, E>

Creates a stream of single element

use futures::prelude::*;
use futures::stream;
use futures_executor::block_on;

let mut stream = stream::once::<(), _>(Err(17));
assert_eq!(Err(17), block_on(stream.collect()));

let mut stream = stream::once::<_, ()>(Ok(92));
assert_eq!(Ok(vec![92]), block_on(stream.collect()));