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
43
44

use crate::Timer;
use futures_util::FutureExt;
use pin_project_lite::pin_project;
use std::{task::Poll, time::Duration};

/// Run the inner [`Future`] until it completes, or `duration` elapses -
/// whichever comes first
pub fn timeout<F: Future>(duration: Duration, future: F) -> std::io::Result<Timeout<F>> {
    let mut timer = Timer::new()?;
    timer.set(nix::sys::timer::Expiration::OneShot(duration.into()))?;
    Ok(Timeout { future, timer })
}

pin_project! {
    pub struct Timeout<F: Future> {
        #[pin]
        future: F,
        timer: Timer,
    }
}

impl<F: Future> Future for Timeout<F> {
    type Output = Result<F::Output, ()>;

    fn poll(self: std::pin::Pin<&mut Self>, cx: &mut std::task::Context<'_>) -> Poll<Self::Output> {
        let this = self.project();

        if let Poll::Ready(ret) = this.future.poll(cx) {
            Poll::Ready(Ok(ret))
        } else if this.timer.tick().poll_unpin(cx).is_ready() {
            Poll::Ready(Err(()))
        } else {
            Poll::Pending
        }
    }
}

/// Sleeps for `duration` before returning
pub async fn sleep(duration: Duration) -> std::io::Result<()> {
    let mut timer = Timer::new()?;
    timer.set(nix::sys::timer::Expiration::OneShot(duration.into()))?;
    timer.tick().await?;
    Ok(())
}