mongodb 2.4.0-beta.1

The official MongoDB driver for Rust
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

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

use crate::runtime;

/// Interval implementation using async-std.
/// For tokio, we just use tokio::time::Interval.
pub(crate) struct Interval {
    interval: Duration,
    last_time: Instant,
}

#[cfg(feature = "async-std-runtime")]
impl Interval {
    pub(super) fn new(interval: Duration) -> Self {
        Self {
            interval,
            last_time: Instant::now(),
        }
    }

    pub(crate) async fn tick(&mut self) -> Instant {
        match self.interval.checked_sub(self.last_time.elapsed()) {
            Some(duration) => {
                runtime::delay_for(duration).await;
                self.last_time = Instant::now();
            }
            None => self.last_time = Instant::now(),
        }
        self.last_time
    }
}