1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

//! Utilities for bridging time and tasks.

use std::future::Future;
use std::time::Duration;

use futures::stream::Stream;

use crate::imp::time as imp;

/// Waits until duration has elapsed.
#[inline(always)]
pub fn sleep(dur: Duration) -> impl Future<Output = ()> {
    imp::sleep(dur)
}

/// Creates a Stream that yields an item after every period has elapsed.
#[inline(always)]
pub fn interval(period: Duration) -> impl Stream<Item = ()> {
    imp::interval(period)
}