epox 0.2.5

An epoll driven async executor.
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

use futures_lite::AsyncBufReadExt;

fn main() {
    epox::spawn(async move {
        asyncmain().await.unwrap();
    });
    epox::run().unwrap();
}

async fn asyncmain() -> Result<(), Box<dyn std::error::Error>> {
    let stdin = std::io::stdin();
    let stdin_fd = epox::futures::AsyncReadFd::new(stdin)?;
    let mut stdin_reader = futures_lite::io::BufReader::new(stdin_fd);
    loop {
        let mut line = String::new();
        stdin_reader.read_line(&mut line).await?;
        let line = line.trim();
        if line == "quit" {
            break;
        }
        println!("got '{line}'");
    }
    Ok(())
}