crb-core-std 0.0.38

CRB | Composable Runtime Blocks | STD
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

//! Utilities for tracking time.

use futures::Future;
pub use std::time::{Duration, Instant};
pub use tokio::time::error::Elapsed;

/// Waits until duration has elapsed.
pub async fn sleep(duration: Duration) {
    tokio::time::sleep(duration).await;
}

/// Requires a Future to complete before
/// the specified duration has elapsed.
///
/// If `duration` is not set it waits for
///  the `fut` completion only.
pub async fn timeout<T>(duration: Option<Duration>, fut: T) -> Result<T::Output, Elapsed>
where
    T: Future,
{
    if let Some(duration) = duration {
        tokio::time::timeout(duration, fut).await
    } else {
        Ok(fut.await)
    }
}