[go: up one dir, main page]

futures 0.1.3

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
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

extern crate futures;

use futures::*;

#[test]
fn ignore_failed() {
    let v = vec![
        failed(1).boxed(),
        failed(2).boxed(),
        finished(3).boxed(),
        finished(4).boxed(),
    ];

    let (i, v) = select_ok(v).wait().ok().unwrap();
    assert_eq!(i, 3);

    assert!(v.len() == 1);

    let (i, v) = select_ok(v).wait().ok().unwrap();
    assert_eq!(i, 4);

    assert!(v.len() == 0);
}

#[test]
fn last_failed() {
    let v = vec![
        finished(1).boxed(),
        failed(2).boxed(),
        failed(3).boxed(),
    ];

    let (i, v) = select_ok(v).wait().ok().unwrap();
    assert_eq!(i, 1);

    assert!(v.len() == 2);

    let i = select_ok(v).wait().err().unwrap();
    assert_eq!(i, 3);
}