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

use aselect::{aselect};
use tokio::net::TcpStream;
use tokio::signal;

#[tokio::main]
async fn main() {
    let connection_attempts = 0u32;
    {
        aselect!(
            {mutable(connection_attempts);},
            ctrl_c(
                 {},
                async | _fut | { signal::ctrl_c().await },
                |ctrl_c_result| {
                    // Cancel the 'conn' arm.
                    conn.cancel();
                    println!(
                        "ctrl-c result: {:?}, after {} attempts",
                        ctrl_c_result,
                        *connection_attempts
                    );
                    (*connection_attempts > 5).then_some(())
                }
            ),
            conn(
                 {
                    *connection_attempts += 1;
                },
                async | _fut | {
                    println!("Reconnecting");
                    let conn = TcpStream::connect(
                        std::env::args()
                            .nth(1)
                            .unwrap_or("127.0.0.1:80".to_string()),
                    )
                    .await;
                    println!("Connection result: {:?}", conn);

                    tokio::time::sleep(std::time::Duration::from_secs(1)).await;
                },
                |conn| {
                    println!("Continue");
                    None
                }
            ),
        )
        .await;
    }
    println!("Done");
}