rat_salsa/poll/
tick.rs

1//!
2//! Triggers a render after some duration has passed.
3//!
4use crate::Control;
5use crate::poll::PollEvents;
6use std::any::Any;
7use std::sync::Arc;
8use std::sync::atomic::{AtomicU64, Ordering};
9use std::time::{Duration, SystemTime};
10
11/// Triggers a render after some duration has passed.
12pub struct PollTick {
13    rate: Arc<AtomicU64>,
14    next: SystemTime,
15}
16
17impl PollTick {
18    /// New FPS trigger.
19    ///
20    /// - start_lag: initial wait in milliseconds.
21    /// - rate: wait between renders in milliseconds.
22    ///
23    /// __Returns__
24    ///
25    /// Returns the Poll and an Arc to the configured duration.
26    pub fn new(start_lag: u64, rate: u64) -> Self {
27        Self::new_config(start_lag, rate).0
28    }
29
30    /// New configurable FPS trigger.
31    ///
32    /// - start_lag: initial wait in milliseconds.
33    /// - rate: wait between renders in milliseconds.
34    ///
35    /// __Returns__
36    ///
37    /// Returns the Poll and an Arc to the configured duration.
38    pub fn new_config(start_lag: u64, rate: u64) -> (Self, Arc<AtomicU64>) {
39        let tick = Self {
40            rate: Arc::new(AtomicU64::new(rate)),
41            next: SystemTime::now() + Duration::from_millis(start_lag),
42        };
43        let tick_cfg = tick.rate.clone();
44        (tick, tick_cfg)
45    }
46}
47
48impl<Event, Error> PollEvents<Event, Error> for PollTick
49where
50    Event: 'static,
51    Error: 'static,
52{
53    fn as_any(&self) -> &dyn Any {
54        self
55    }
56
57    fn poll(&mut self) -> Result<bool, Error> {
58        Ok(self.next <= SystemTime::now())
59    }
60
61    fn read(&mut self) -> Result<Control<Event>, Error> {
62        if self.next <= SystemTime::now() {
63            let rate = self.rate.load(Ordering::Acquire);
64            self.next += Duration::from_millis(rate);
65            Ok(Control::Changed)
66        } else {
67            Ok(Control::Continue)
68        }
69    }
70}
rat_salsa/poll/tick.rs

rat_salsa/poll/
tick.rs
