aselect 0.2.0

Opinionated replacement for tokio::select!, avoiding certain pitfalls.
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

use aselect::{aselect};

#[tokio::main]
async fn main() {
    let server = false;
    aselect!(
        {
            mutable(server);
        },
        accepted(
            {
                let mut server : &mut bool = server;
                if !*server {
                    println!("Not time to be server");
                    return None;
                };
                println!("Server");
            },
            async | _input |{
                println!("Do server stuff");
                tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
                println!("Done server stuff");
            },
            |result|{
                *server = false;
                println!("Server future completed");
                None
            }
        ),
        connection_result(
             {
                 if *server {
                    println!("Not time to be client");
                    return None;
                };
                println!("not server");
            },
            async | _input |{
                println!("Do client stuff");
                tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
                println!("Done client stuff");
            },
            |connection_result| {
                *server = true;
                println!("Client future completed");
                None
            }
        ),
        timer(
            {},
            async | _input | {
                tokio::time::sleep(tokio::time::Duration::from_secs(1000)).await;
            },
            |timer| {
                println!("Timer");
                Some("finished")
            }
        ),
    )
    .await;
}