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
32
33
34
35
36
37
38
39
40
41
42

use epox::Timer;

const TIMEOUT_DURATION: std::time::Duration = std::time::Duration::from_secs(1);

#[test]
fn timeout() {
    let handle = epox::spawn_checked(async {
        match epox::time::timeout(TIMEOUT_DURATION, takes_one_minute())?.await {
            Ok(_) => Ok::<_, Box<dyn std::error::Error>>(false),
            Err(()) => Ok(true),
        }
    });

    let begin = std::time::Instant::now();
    epox::run().unwrap();
    let took = std::time::Instant::now().duration_since(begin);
    let handle_timed_out = handle.result().expect("task should have finished").unwrap();
    assert!(handle_timed_out);
    // should be within 5% of TIMEOUT_DURATION
    assert!(took.abs_diff(TIMEOUT_DURATION) < (TIMEOUT_DURATION / 20));
}

async fn takes_one_minute() -> std::io::Result<()> {
    let mut timer = Timer::new()?;
    timer.set(nix::sys::timer::Expiration::OneShot(
        std::time::Duration::from_secs(60 * 2).into(),
    ))?;
    timer.tick().await?;
    Ok(())
}

#[test]
fn sleep() {
    epox::spawn(async {
        epox::time::sleep(TIMEOUT_DURATION).await.unwrap();
    });

    let begin = std::time::Instant::now();
    epox::run().unwrap();
    let took = std::time::Instant::now().duration_since(begin); // should be within 5% of TIMEOUT_DURATION
    assert!(took.abs_diff(TIMEOUT_DURATION) < (TIMEOUT_DURATION / 20));
}