async-exec 0.1.1

Simple async task executor with a built-in HTTP task monitor
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

//! Future Timing Utilities

use std::future::Future;
use std::time::{Duration, Instant};

use async_io::Timer;
use futures_lite::future::or;

/// This trait adds a `timeout` method to all futures.
pub trait FutureTimeout<T>: Future<Output = T> + Sized {
    /// This method, implemented for all futures, returns another future which
    /// yields None if the inner future takes too long to yield its output.
    ///
    /// If the inner future yields in time, its output is in turn yielded in `Some(_)`.
    fn timeout(self, duration: Duration) -> impl Future<Output = Option<T>> {
        let this = async { Some(self.await) };

        let timeout = async move {
            sleep(duration).await;
            None
        };

        or(this, timeout)
    }
}

impl<T, F: Future<Output = T>> FutureTimeout<T> for F {}

/// Pauses the current task for some time.
pub async fn sleep(duration: Duration) {
    Timer::after(duration).await;
}

/// Pauses the current task until an expiration instant.
pub async fn sleep_until(instant: Instant) {
    Timer::at(instant).await;
}