completeio 0.1.0

Completion based IO drivers and async runtime
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

use std::time::Duration;

use completeio::{signal::ctrl_c, time::interval};
use futures_util::{select, FutureExt};

fn main() {
    completeio::task::block_on(async {
        let mut interval = interval(Duration::from_secs(2));
        loop {
            let mut ctrlc = ctrl_c();
            let ctrlc = std::pin::pin!(ctrlc);
            select! {
                res = ctrlc.fuse() => {
                    res.unwrap();
                    println!("break");
                    break;
                },
                _ = interval.tick().fuse() => println!("ping"),
            }
        }
        println!("exit first loop");
        loop {
            interval.tick().await;
            println!("ping");
        }
    })
}