ert 0.2.2

A combinator to control future execution order.
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
41
42
43
44
45
46

mod helper;

use self::helper::Checker;
use ert::prelude::*;
use futures::prelude::*;

#[tokio::test]
async fn global_uninit() {
    env_logger::init();

    let c = Checker::new();

    let c1 = c.clone();
    let futs: Vec<_> = (0u64..100)
        .map(move |i| {
            let c1 = c1.clone();
            async move {
                c1.add(i);
            }
            .via_g(i)
        })
        .collect();

    let c2 = c.clone();
    let futs2: Vec<_> = (0u64..10000)
        .map(move |i| {
            let i = i % 100;
            let c2 = c2.clone();
            async move {
                c2.check(i);
            }
            .via_g(i)
        })
        .collect();

    let f = futures::future::join_all(futs)
        .then(|r| {
            assert_eq!(r.len(), 100);
            futures::future::join_all(futs2)
        })
        .then(|r| async move {
            assert_eq!(r.len(), 10000);
        });

    f.await;
}