refactor!: rework scheduled actions API

Cargo.toml

@@ -17,7 +17,7 @@ members = ["fastimer", "fastimer-driver", "fastimer-tokio", "xtask"]
 resolver = "2"
 
 [workspace.package]
-edition = "2021"
+edition = "2024"
 homepage = "https://github.com/fast/fastimer"
 license = "Apache-2.0"
 readme = "README.md"

fastimer-driver/src/heap.rs

@@ -14,9 +14,9 @@
 
 use std::collections::BinaryHeap;
 use std::ops::ControlFlow;
+use std::sync::Arc;
 use std::sync::atomic;
 use std::sync::atomic::AtomicBool;
-use std::sync::Arc;
 use std::time::Duration;
 use std::time::Instant;
 

fastimer-driver/src/lib.rs

@@ -20,18 +20,18 @@
 use std::cmp;
 use std::future::Future;
 use std::pin::Pin;
+use std::sync::Arc;
 use std::sync::atomic;
 use std::sync::atomic::AtomicBool;
-use std::sync::Arc;
 use std::task::Context;
 use std::task::Poll;
 use std::time::Duration;
 use std::time::Instant;
 
 use atomic_waker::AtomicWaker;
 use crossbeam_queue::SegQueue;
-use fastimer::make_instant_from_now;
 use fastimer::MakeDelay;
+use fastimer::make_instant_from_now;
 use parking::Unparker;
 
 mod heap;

fastimer-driver/tests/integration.rs

@@ -29,10 +29,12 @@ fn assert_duration_eq(actual: Duration, expected: Duration) {
 fn test_binary_heap_driver() {
     let (mut driver, context, shutdown) = binary_heap_driver();
     let (tx, rx) = std::sync::mpsc::channel();
-    std::thread::spawn(move || loop {
-        if driver.turn().is_break() {
-            tx.send(()).unwrap();
-            break;
+    std::thread::spawn(move || {
+        loop {
+            if driver.turn().is_break() {
+                tx.send(()).unwrap();
+                break;
+            }
         }
     });
 

fastimer/Cargo.toml

@@ -39,6 +39,8 @@ pin-project = { version = "1.1.9" }
 log = { version = "0.4.22", features = ["kv"], optional = true }
 
 [dev-dependencies]
+log = { version = "0.4.22", features = ["kv"] }
+logforth = { version = "0.24.0", features = ["colored"] }
 tokio = { workspace = true, features = ["full"] }
 
 [lints]

fastimer/src/interval.rs

@@ -17,17 +17,17 @@
 //
 // [1] https://github.com/tokio-rs/tokio/blob/b8ac94ed/tokio/src/time/interval.rs
 
-use std::future::poll_fn;
 use std::future::Future;
+use std::future::poll_fn;
 use std::pin::Pin;
-use std::task::ready;
 use std::task::Context;
 use std::task::Poll;
+use std::task::ready;
 use std::time::Duration;
 use std::time::Instant;
 
-use crate::far_future;
 use crate::MakeDelay;
+use crate::far_future;
 
 /// Creates new [`Interval`] that yields with interval of `period`. The first
 /// tick completes immediately. The default [`MissedTickBehavior`] is
@@ -49,8 +49,8 @@ use crate::MakeDelay;
 /// use std::time::Duration;
 /// use std::time::Instant;
 ///
-/// use fastimer::interval;
 /// use fastimer::MakeDelay;
+/// use fastimer::interval;
 ///
 /// struct TokioDelay;
 /// impl MakeDelay for TokioDelay {
@@ -85,8 +85,8 @@ use crate::MakeDelay;
 /// use std::time::Duration;
 /// use std::time::Instant;
 ///
-/// use fastimer::interval;
 /// use fastimer::MakeDelay;
+/// use fastimer::interval;
 ///
 /// struct TokioDelay;
 /// impl MakeDelay for TokioDelay {
@@ -139,8 +139,8 @@ pub fn interval<D: MakeDelay>(period: Duration, make_delay: D) -> Interval<D> {
 /// use std::time::Duration;
 /// use std::time::Instant;
 ///
-/// use fastimer::interval_at;
 /// use fastimer::MakeDelay;
+/// use fastimer::interval_at;
 ///
 /// struct TokioDelay;
 /// impl MakeDelay for TokioDelay {

fastimer/src/lib.rs

@@ -130,7 +130,7 @@ impl<T: MakeDelay> MakeDelayExt for T {}
 pub(crate) use self::macros::debug;
 pub(crate) use self::macros::info;
 
-#[cfg(feature = "logging")]
+#[cfg(any(test, feature = "logging"))]
 mod macros {
     macro_rules! debug {
         (target: $target:expr, $($arg:tt)+) => (log::debug!(target: $target, $($arg)+));
@@ -146,7 +146,7 @@ mod macros {
     pub(crate) use info;
 }
 
-#[cfg(not(feature = "logging"))]
+#[cfg(not(any(test, feature = "logging")))]
 #[macro_use]
 mod macros {
     macro_rules! info {