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
25
26

use futures_lite::AsyncBufReadExt;

fn main() {
    let handle = epox::spawn_checked(async {
        let mut stdin_reader =
            futures_lite::io::BufReader::new(epox::futures::AsyncReadFd::new(std::io::stdin())?);
        let mut line = String::new();
        match epox::time::timeout(std::time::Duration::from_secs(2), async move {
            stdin_reader.read_line(&mut line).await?;
            let line = line.trim();
            println!("read line: {line}");
            Ok::<_, Box<dyn std::error::Error>>(())
        })?
        .await
        {
            Ok(ret) => {
                ret?;
            }
            Err(()) => println!("timed out waiting for line"),
        }
        Ok::<_, Box<dyn std::error::Error>>(())
    });

    epox::run().unwrap();
    handle.result().unwrap().unwrap();
}