Update embassy-time

Author: bugadani

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "async-io-mini"
-version = "0.2.0"
+version = "0.3.0"
 authors = ["Stjepan Glavina <[email protected]>", "Ivan Markov"]
 edition = "2021"
 rust-version = "1.77"
@@ -13,7 +13,7 @@ exclude = ["/.*"]
 
 [features]
 default = ["futures-io", "futures-lite", "embassy-time"]
-embassy-time = ["embassy-time-driver", "embassy-time-queue-driver", "dep:embassy-time"]
+embassy-time = ["embassy-time-driver", "dep:embassy-time"]
 
 [dependencies]
 libc = "0.2"
@@ -22,14 +22,14 @@ heapless = "0.8"
 log = { version = "0.4", default-features = false }
 futures-io = { version = "0.3", default-features = false, optional = true, features = ["std"] }
 futures-lite = { version = "2", default-features = false, optional = true }
-embassy-time-driver = { version = "0.1", optional = true }
-embassy-time-queue-driver = { version = "0.1", optional = true }
-embassy-time = { version = "0.3", optional = true }
+embassy-time-driver = { version = "0.2", optional = true }
+embassy-time = { version = "0.4", optional = true }
 
 [dev-dependencies]
 futures-io = "0.3"
 futures-lite = "2"
-embassy-time = { version = "0.3", features = ["std", "generic-queue"] }
+embassy-time = { version = "0.4", features = ["std"] }
+embassy-time-queue-utils = { version = "0.1", features = ["generic-queue-64"] }
 async-channel = "2"
 env_logger = "0.10"
 

src/timer.rs

@@ -283,7 +283,7 @@ impl Timer {
             self.period = Duration::MAX;
 
             if let Some(waker) = self.waker.as_ref() {
-                embassy_time_queue_driver::schedule_wake(ticks, waker);
+                embassy_time_driver::schedule_wake(ticks, waker);
             }
         } else {
             self.set_never();
@@ -347,7 +347,7 @@ impl Timer {
             self.period = period;
 
             if let Some(waker) = self.waker.as_ref() {
-                embassy_time_queue_driver::schedule_wake(ticks, waker);
+                embassy_time_driver::schedule_wake(ticks, waker);
             }
         } else {
             // Overflow to never going off.
@@ -375,7 +375,7 @@ impl Timer {
                     .unwrap_or(true)
                 {
                     self.waker = Some(cx.waker().clone());
-                    embassy_time_queue_driver::schedule_wake(ticks, cx.waker());
+                    embassy_time_driver::schedule_wake(ticks, cx.waker());
                 }
             } else {
                 self.set_never();