nio 0.1.4

Async runtime for Rust
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

use nio::{TaskId, spawn, spawn_local, test};
use nio_future::yield_now;

async fn task_id() -> TaskId {
    let id = async { nio::task_id().await };
    yield_now().await;
    let id = id.await;
    yield_now().await;
    assert_eq!(id, nio::task_id().await);
    id
}

#[test]
async fn task_id_local() {
    let jh = spawn_local(async { task_id().await });
    let id1 = jh.abort_handle().id();
    let id2 = jh.id();

    yield_now().await;
    let id3 = jh.await.unwrap();

    assert_eq!(id1, id2);
    assert_eq!(id1, id3);
    assert_eq!(id2, id3);
}

#[test]
async fn task_id_spawn() {
    let jh = spawn(async { task_id().await });
    let id1 = jh.abort_handle().id();
    let id2 = jh.id();

    yield_now().await;
    let id3 = jh.await.unwrap();

    assert_eq!(id1, id2);
    assert_eq!(id1, id3);
    assert_eq!(id2, id3);
}

#[test]
async fn task_id_collision_local() {
    let h1 = spawn_local(async { task_id().await });
    let h2 = spawn_local(async { task_id().await });

    let (id1, id2) = futures::join!(h1, h2);
    assert_ne!(id1.unwrap(), id2.unwrap());
}

#[test]
async fn task_id_collision_spawn() {
    let h1 = spawn(async { task_id().await });
    let h2 = spawn(async { task_id().await });

    let (id1, id2) = futures::join!(h1, h2);
    assert_ne!(id1.unwrap(), id2.unwrap());
}