[go: up one dir, main page]

futures 0.1.0

An implementation of futures and streams featuring zero allocations, composability, and iterator-like interfaces.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

extern crate futures;

use std::sync::mpsc::channel;

use futures::*;

#[test]
fn lots() {
    fn doit(n: usize) -> Box<Future<Item=(), Error=()>> {
        if n == 0 {
            finished(()).boxed()
        } else {
            finished(n - 1).and_then(doit).boxed()
        }
    }

    let (tx, rx) = channel();
    doit(1_000).map(move |_| tx.send(()).unwrap()).forget();
    rx.recv().unwrap();
}