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
41
42
43
44
45
46
47
48
49
50
51
52
|
extern crate futures;
mod support;
use futures::stream;
use support::*;
#[test]
fn unfold1() {
let mut stream = stream::unfold(0, |state| {
if state <= 2 {
let res: Result<_,()> = Ok((state * 2, state + 1));
Some(delay_future(res))
} else {
None
}
});
// Creates the future with the closure
// Not ready (delayed future)
sassert_empty(&mut stream);
// future is ready, yields the item
sassert_next(&mut stream, 0);
// Repeat
sassert_empty(&mut stream);
sassert_next(&mut stream, 2);
sassert_empty(&mut stream);
sassert_next(&mut stream, 4);
// no more items
sassert_done(&mut stream);
}
#[test]
fn unfold_err1() {
let mut stream = stream::unfold(0, |state| {
if state <= 2 {
Some(Ok((state * 2, state + 1)))
} else {
Some(Err(-1))
}
});
sassert_next(&mut stream, 0);
sassert_next(&mut stream, 2);
sassert_next(&mut stream, 4);
sassert_err(&mut stream, -1);
// An error was generated by the stream, it will then finish
sassert_done(&mut stream);
}
|
