futures-async-combinators 0.2.0

toy futures combinators
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

#![feature(futures_api, async_await, await_macro)]

use futures_async_combinators::stream::*;
use futures::executor;

fn main() {
    let stream = iter(1..=3);
    let stream = map(stream, |x| x + 1);
    let stream = map(stream, |x| x * 2);

    let collect_future = collect(stream);
    let collection : Vec<_> = executor::block_on(collect_future);

    assert_eq!(vec![4, 6, 8], collection);
}