rocketman 0.4.0

A modular(ish) jetstream consumer.
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

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

use super::TimeProvider;

#[derive(Default, Clone, Copy)] // Add these derives for ease of use
pub struct SystemTimeProvider; // No fields needed, just a marker type

impl TimeProvider for SystemTimeProvider {
    fn new() -> Self {
        Self
    }

    fn now(&self) -> SystemTime {
        SystemTime::now()
    }

    fn elapsed(&self, earlier: SystemTime) -> Duration {
        earlier.elapsed().unwrap_or_else(|_| Duration::from_secs(0))
    }

    fn instant_now(&self) -> Instant {
        Instant::now()
    }

    fn instant_elapsed(&self, earlier: Instant) -> Duration {
        earlier.elapsed()
    }
}