oura 2.2.0

The tail of Cardano
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
38

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

const THROTTLE_MIN_SPAN_MILLIS: u64 = 300;

pub struct Throttle {
    last_action: Instant,
    min_delay: Duration,
}

impl Throttle {
    pub fn new(min_delay: Duration) -> Throttle {
        Throttle {
            last_action: Instant::now(),
            min_delay,
        }
    }

    pub fn wait_turn(&mut self) {
        let remaining = self.min_delay.checked_sub(self.last_action.elapsed());

        if let Some(remaining) = remaining {
            sleep(remaining);
        }

        self.last_action = Instant::now();
    }
}

impl From<Option<u64>> for Throttle {
    fn from(value: Option<u64>) -> Self {
        let millis = value.unwrap_or(THROTTLE_MIN_SPAN_MILLIS);
        let duration = Duration::from_millis(millis);
        Throttle::new(duration)
    }
}