awak 0.2.36

A small 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

use std::io;
use std::time::Duration;

use awak::net::UnixListener;
use awak::time::delay_for;
use futures_util::AsyncWriteExt;

fn main() -> io::Result<()> {
    awak::block_on(async {
        let listener = UnixListener::bind("temp.sock")?;
        println!("server start at temp.sock");
        loop {
            let (mut stream, _) = listener.accept().await?;
            awak::spawn(async move {
                loop {
                    delay_for(Duration::from_secs(1)).await;
                    match stream.write_all(b"helloworld").await {
                        Ok(_) => {
                            println!("write bytes succ");
                        }
                        Err(e) => {
                            println!("write bytes err: {:?}", e);
                            break;
                        }
                    }
                }
            })
            .detach();
        }
    })
}