TickedTimer API

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ticked_async_executor"
-version = "0.2.0"
+version = "0.2.1"
 authors = ["coder137"]
 edition = "2021"
 description = "Local executor that runs woken async tasks when it is ticked"

src/split_ticked_async_executor.rs

@@ -89,7 +89,7 @@ where
 
     pub fn create_timer(&self) -> TickedTimer {
         let tick_recv = self.rx_tick_event.clone();
-        TickedTimer { tick_recv }
+        TickedTimer::new(tick_recv)
     }
 
     pub fn tick_channel(&self) -> tokio::sync::watch::Receiver<f64> {

src/ticked_timer.rs

@@ -1,8 +1,12 @@
 pub struct TickedTimer {
-    pub tick_recv: tokio::sync::watch::Receiver<f64>,
+    tick_recv: tokio::sync::watch::Receiver<f64>,
 }
 
 impl TickedTimer {
+    pub fn new(tick_recv: tokio::sync::watch::Receiver<f64>) -> Self {
+        Self { tick_recv }
+    }
+
     pub async fn sleep_for(mut self, mut duration_in_ms: f64) {
         loop {
             let _r = self.tick_recv.changed().await;