rt-local 0.1.4

Thread local asynchronous runtime working with platform-specific event loops.
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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97

use crate::run;
use crate::test_utils::*;
use async_std::task::sleep;
use rt_local_core::*;
use std::time::Duration;

#[test]
fn test_run() {
    let mut executed = false;
    run(async {
        executed = true;
    });
    assert!(executed);
}

#[test]
fn test_sleep() {
    let mut executed = false;
    run(async {
        sleep(Duration::from_secs(1)).await;
        executed = true;
    });
    assert!(executed);
}

#[test]
fn test_spawn_local() {
    let p = AssertPass::new();
    run(async {
        let p1 = p.clone();
        spawn_local(async move {
            sleep(Duration::from_secs(1)).await;
            p1.pass("1");
        })
        .await;
        p.pass("2");
    });
    p.assert(&["1", "2"]);
}

#[test]
fn test_cancel() {
    let p = AssertPass::new();
    run(async {
        let p1 = p.clone();
        drop(spawn_local(async move {
            p1.pass("1");
        }));
        sleep(Duration::from_secs(1)).await;
        p.pass("2");
    });
    p.assert(&["2"]);
}

#[test]
fn test_detach() {
    let p = AssertPass::new();
    run(async {
        let p1 = p.clone();
        spawn_local(async move {
            p1.pass("1");
        })
        .detach();
        sleep(Duration::from_secs(1)).await;
        p.pass("2");
    });
    p.assert(&["1", "2"]);
}

#[test]
fn test_wait_for_idle() {
    let p = AssertPass::new();
    run(async {
        p.pass("1");
        wait_for_idle().await;
        p.pass("2");
    });
    p.assert(&["1", "2"]);
}

#[test]
fn test_wait_for_idle_many() {
    let p1 = AssertPass::new_with(true);
    run(async {
        p1.pass("1-a");
        let p2 = p1.clone();
        let t = spawn_local(async move {
            p2.pass("2-a");
            wait_for_idle().await;
            p2.pass("2-b");
        });
        wait_for_idle().await;
        p1.pass("1-b");
        t.await;
    });
    p1.assert_ex(&[&["1-a"], &["2-a"], &["1-b", "2-b"]]);
}