mioco 0.8.1

Scalable, asynchronous IO coroutine-based handling (aka MIO COroutines).
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

extern crate mioco;
extern crate env_logger;

/// Example on how to shutdown mioco instance from "the outside".
fn main() {
    env_logger::init().unwrap();

    let (terminate_tx, terminate_rx) = mioco::sync::mpsc::channel();

    println!("Spawning mioco instance");
    mioco::spawn(move || {
        mioco::spawn(move || {
            let _ = terminate_rx.recv();
            mioco::shutdown();
        });

        for _ in 0..32 {
            mioco::spawn(move|| {
                loop {
                    mioco::yield_now();
                }
            });
        }
    });

    println!("Sleeping");
    std::thread::sleep(std::time::Duration::from_secs(1));

    println!("Terminating mioco instance");
    terminate_tx.send(()).unwrap();
}