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
27
28
29
30
31

use clap::Parser;
use std::io::Read;

#[derive(Parser)]
struct Args {
    #[clap(default_value = "/dev/ttyUSB0")]
    port: String,
    #[clap(default_value_t = 115_200)]
    baud_rate: u32,
}

fn main() {
    let args = Args::parse();
    let mut serial = epox::Fd::new(
        serialport::new(args.port, args.baud_rate)
            .open_native()
            .unwrap(),
        epox::EpollFlags::EPOLLIN,
    )
    .unwrap();
    epox::spawn(async move {
        println!("waiting for serial data...");
        let mut buf = [0; 32];
        let len = serial
            .with_mut(|fd, _events| fd.read(&mut buf))
            .await
            .unwrap();
        println!("read {:#?}", &buf[0..len]);
    });
    epox::run().unwrap();
}