async-hybrid-sleep 0.1.1

Hybrid async sleep combining runtime timers with spin-sleeping for sub-millisecond accuracy
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

/// Tokio-backed clock implementation, used when the `tokio` feature is enabled.
#[derive(Debug, Clone, Default)]
pub struct Clock;

impl Clock {
    pub fn new() -> Self {
        Self
    }
}

/// Delegates time operations to the Tokio runtime.
impl crate::Clock for Clock {
    type Instant = tokio::time::Instant;
    type SleepFuture = tokio::time::Sleep;

    fn now(&self) -> Self::Instant {
        tokio::time::Instant::now()
    }

    fn sleep(&self, duration: std::time::Duration) -> Self::SleepFuture {
        tokio::time::sleep(duration)
    }
}

/// Bridges [`tokio::time::Instant`] into the [`InstantExt`](crate::InstantExt) abstraction.
impl crate::InstantExt for tokio::time::Instant {
    fn saturating_duration_since(&self, earlier: Self) -> std::time::Duration {
        self.checked_duration_since(earlier)
            .unwrap_or(std::time::Duration::ZERO)
    }
}