futures 0.1.12

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
21
22
23
24

extern crate futures;

use std::thread;

use futures::{Sink, Stream, Future};
use futures::sync::mpsc::*;

#[test]
fn smoke() {
    let (mut sender, receiver) = channel(1);

    let t = thread::spawn(move ||{
        loop {
            match sender.send(42).wait() {
                Ok(s) => sender = s,
                Err(_) => break,
            }
        }
    });

    receiver.take(3).for_each(|_| Ok(())).wait().unwrap();

    t.join().unwrap()
}