From e1b652799e595547caa21dabfa8d7dee2c7eac81 Mon Sep 17 00:00:00 2001 From: chenmch Date: Wed, 4 Mar 2026 14:33:39 +0800 Subject: [PATCH 1/2] Fix typo: spwan_async -> spawn_async - Fixed method name typo in TaskBuilder across all examples and tests - Updated src/task/task.rs and src/timer/wheel.rs with correct method name --- examples/advance_task.rs | 4 ++-- examples/concurrency_control.rs | 2 +- examples/countdown_task.rs | 2 +- examples/once_delayed_task.rs | 2 +- examples/repeated_task.rs | 2 +- examples/task_management.rs | 6 +++--- src/task/task.rs | 2 +- src/timer/wheel.rs | 20 ++++++++++---------- tests/advance_task.rs | 18 +++++++++--------- tests/concurrency_boundary.rs | 8 ++++---- tests/error_handling.rs | 4 ++-- tests/performance.rs | 4 ++-- tests/task_execution.rs | 16 ++++++++-------- tests/task_failure.rs | 2 +- tests/task_management.rs | 16 ++++++++-------- tests/time_wheel_cascade.rs | 28 ++++++++++++++-------------- tests/timer_lifecycle.rs | 8 ++++---- 17 files changed, 72 insertions(+), 72 deletions(-) diff --git a/examples/advance_task.rs b/examples/advance_task.rs index b210887..ed199ee 100644 --- a/examples/advance_task.rs +++ b/examples/advance_task.rs @@ -27,7 +27,7 @@ async fn main() { let task = TaskBuilder::new(1) .with_frequency_repeated_by_seconds(60) - .spwan_async(CounterTask { + .spawn_async(CounterTask { id: 1, counter: counter.clone(), }) @@ -64,7 +64,7 @@ async fn main() { println!("\n--- Test 3: Advance beyond wait time ---"); let task2 = TaskBuilder::new(2) .with_frequency_repeated_by_seconds(60) - .spwan_async(CounterTask { + .spawn_async(CounterTask { id: 2, counter: counter.clone(), }) diff --git a/examples/concurrency_control.rs b/examples/concurrency_control.rs index 76b531a..3e383ad 100644 --- a/examples/concurrency_control.rs +++ b/examples/concurrency_control.rs @@ -45,7 +45,7 @@ async fn main() { let task = TaskBuilder::new(i) .with_frequency_once_by_seconds(1) .with_max_concurrency(max_concurrency) - .spwan_async(ConcurrentTask { + .spawn_async(ConcurrentTask { task_id: i, active_count: active_count.clone(), }) diff --git a/examples/countdown_task.rs b/examples/countdown_task.rs index ed51b28..ab7c6f3 100644 --- a/examples/countdown_task.rs +++ b/examples/countdown_task.rs @@ -25,7 +25,7 @@ async fn main() { let task = TaskBuilder::new(1) .with_frequency_count_down_by_seconds(3, 1) - .spwan_async(CountDownTask { + .spawn_async(CountDownTask { counter: counter.clone(), }) .unwrap(); diff --git a/examples/once_delayed_task.rs b/examples/once_delayed_task.rs index 64a64a1..aac2169 100644 --- a/examples/once_delayed_task.rs +++ b/examples/once_delayed_task.rs @@ -21,7 +21,7 @@ async fn main() { let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(3) - .spwan_async(DelayedPrintTask { + .spawn_async(DelayedPrintTask { message: "Hello from minitimer!".to_string(), }) .unwrap(); diff --git a/examples/repeated_task.rs b/examples/repeated_task.rs index af00039..5423c1a 100644 --- a/examples/repeated_task.rs +++ b/examples/repeated_task.rs @@ -25,7 +25,7 @@ async fn main() { let task = TaskBuilder::new(1) .with_frequency_repeated_by_seconds(1) - .spwan_async(PeriodicTask { + .spawn_async(PeriodicTask { counter: counter.clone(), }) .unwrap(); diff --git a/examples/task_management.rs b/examples/task_management.rs index 2e940a7..ff5f885 100644 --- a/examples/task_management.rs +++ b/examples/task_management.rs @@ -21,17 +21,17 @@ async fn main() { let task1 = TaskBuilder::new(1) .with_frequency_repeated_by_seconds(2) - .spwan_async(SimpleTask { id: 1 }) + .spawn_async(SimpleTask { id: 1 }) .unwrap(); let task2 = TaskBuilder::new(2) .with_frequency_once_by_seconds(5) - .spwan_async(SimpleTask { id: 2 }) + .spawn_async(SimpleTask { id: 2 }) .unwrap(); let task3 = TaskBuilder::new(3) .with_frequency_count_down_by_seconds(3, 1) - .spwan_async(SimpleTask { id: 3 }) + .spawn_async(SimpleTask { id: 3 }) .unwrap(); timer.add_task(task1).unwrap(); diff --git a/src/task/task.rs b/src/task/task.rs index b1d567f..50858cb 100644 --- a/src/task/task.rs +++ b/src/task/task.rs @@ -158,7 +158,7 @@ impl TaskBuilder { /// # Returns /// * `Ok(Task)` - If the task was successfully built /// * `Err(TaskError)` - If there was an error building the task - pub fn spwan_async + Send + Sync>( + pub fn spawn_async + Send + Sync>( self, task_runner: T, ) -> Result { diff --git a/src/timer/wheel.rs b/src/timer/wheel.rs index 14f00f7..c632725 100644 --- a/src/timer/wheel.rs +++ b/src/timer/wheel.rs @@ -1024,7 +1024,7 @@ mod tests { // Add a task to minute wheel slot 0 let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(60) - .spwan_async(TestTaskRunner::new()) + .spawn_async(TestTaskRunner::new()) .unwrap(); multi_wheel.min_wheel.add_task(task, 0); @@ -1061,7 +1061,7 @@ mod tests { // Add a task to hour wheel slot 0 (last hour of the day) let mut task = TaskBuilder::new(2) .with_frequency_once_by_seconds(3600) - .spwan_async(TestTaskRunner::new()) + .spawn_async(TestTaskRunner::new()) .unwrap(); // Set the task's wheel position to simulate it being at the end of the day @@ -1096,7 +1096,7 @@ mod tests { let wheel = MulitWheel::new(); let task = TaskBuilder::new(100) .with_frequency_once_by_seconds(10) - .spwan_async(TestTaskRunner::new()) + .spawn_async(TestTaskRunner::new()) .unwrap(); // Add task to wheel @@ -1114,7 +1114,7 @@ mod tests { // Manually create a task and add it to minute wheel slot 5 let mut task = TaskBuilder::new(105) .with_frequency_once_by_seconds(60) // Next execution in 60 seconds - .spwan_async(TestTaskRunner::new()) + .spawn_async(TestTaskRunner::new()) .unwrap(); // Set up cascade guide to place task in minute wheel slot 5 @@ -1163,7 +1163,7 @@ mod tests { // Create a task that should go to hour wheel (in 3600+ seconds) let mut task = TaskBuilder::new(102) .with_frequency_once_by_seconds(3665) // 3665 seconds from now (1h 1m 5s) - .spwan_async(TestTaskRunner::new()) + .spawn_async(TestTaskRunner::new()) .unwrap(); // Manually set the wheel position to make the task go to hour wheel @@ -1208,7 +1208,7 @@ mod tests { let wheel = MulitWheel::new(); let task = TaskBuilder::new(103) .with_frequency_once_by_seconds(5) - .spwan_async(TestTaskRunner::new()) + .spawn_async(TestTaskRunner::new()) .unwrap(); // Add task to wheel @@ -1322,7 +1322,7 @@ mod tests { let task = TaskBuilder::new(1) .with_frequency_repeated_by_seconds(60) - .spwan_async(TestTaskRunner::new()) + .spawn_async(TestTaskRunner::new()) .unwrap(); wheel.add_task(task).unwrap(); @@ -1342,7 +1342,7 @@ mod tests { let task = TaskBuilder::new(2) .with_frequency_repeated_by_seconds(60) - .spwan_async(TestTaskRunner::new()) + .spawn_async(TestTaskRunner::new()) .unwrap(); wheel.add_task(task).unwrap(); @@ -1368,7 +1368,7 @@ mod tests { let task = TaskBuilder::new(3) .with_frequency_repeated_by_seconds(60) - .spwan_async(TestTaskRunner::new()) + .spawn_async(TestTaskRunner::new()) .unwrap(); wheel.add_task(task).unwrap(); @@ -1525,7 +1525,7 @@ mod tests { // Create a task that runs in 5 minutes (300 seconds) let task = TaskBuilder::new(200) .with_frequency_once_by_seconds(300) - .spwan_async(TestTaskRunner::new()) + .spawn_async(TestTaskRunner::new()) .unwrap(); wheel.add_task(task).unwrap(); diff --git a/tests/advance_task.rs b/tests/advance_task.rs index ba2a1b4..53ea0ca 100644 --- a/tests/advance_task.rs +++ b/tests/advance_task.rs @@ -23,7 +23,7 @@ async fn test_advance_task_by_duration() { let task = TaskBuilder::new(10) .with_frequency_repeated_by_seconds(60) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -69,7 +69,7 @@ async fn test_advance_task_trigger_immediately() { let task = TaskBuilder::new(11) .with_frequency_repeated_by_seconds(60) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -114,7 +114,7 @@ async fn test_advance_task_exceed_wait_time() { let task = TaskBuilder::new(12) .with_frequency_repeated_by_seconds(60) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -165,7 +165,7 @@ async fn test_advance_task_reset_frequency_behavior() { let task = TaskBuilder::new(13) .with_frequency_repeated_by_seconds(60) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -219,7 +219,7 @@ async fn test_advance_task_zero_duration() { let task = TaskBuilder::new(14) .with_frequency_repeated_by_seconds(60) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -277,7 +277,7 @@ async fn test_advance_task_once_triggers_immediately() { let task = TaskBuilder::new(15) .with_frequency_once_by_seconds(60) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -328,7 +328,7 @@ async fn test_advance_task_once_removed_after_execution() { let task = TaskBuilder::new(16) .with_frequency_once_by_seconds(60) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -381,7 +381,7 @@ async fn test_advance_task_reset_frequency_true() { // Create a repeated task with 60-second interval let task = TaskBuilder::new(17) .with_frequency_repeated_by_seconds(60) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -454,7 +454,7 @@ async fn test_advance_task_reset_frequency_multi_round() { // Create a repeated task with 60-second interval let task = TaskBuilder::new(18) .with_frequency_repeated_by_seconds(60) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); diff --git a/tests/concurrency_boundary.rs b/tests/concurrency_boundary.rs index d90d30e..0caceb3 100644 --- a/tests/concurrency_boundary.rs +++ b/tests/concurrency_boundary.rs @@ -23,7 +23,7 @@ async fn test_max_concurrency_respected() { let task = TaskBuilder::new(1) .with_frequency_repeated_by_seconds(1) .with_max_concurrency(1) - .spwan_async(SlowTask::new(counter.clone(), 500)) + .spawn_async(SlowTask::new(counter.clone(), 500)) .unwrap(); timer.add_task(task).unwrap(); @@ -52,7 +52,7 @@ async fn test_one_second_interval() { let task = TaskBuilder::new(1) .with_frequency_repeated_by_seconds(1) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -76,7 +76,7 @@ async fn test_countdown_one_execution() { let task = TaskBuilder::new(1) .with_frequency_count_down_by_seconds(1, 1) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -101,7 +101,7 @@ async fn test_very_long_interval_task() { // 100000 seconds = ~27.8 hours let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(100000) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); diff --git a/tests/error_handling.rs b/tests/error_handling.rs index 4da24ca..cf8c4e1 100644 --- a/tests/error_handling.rs +++ b/tests/error_handling.rs @@ -21,12 +21,12 @@ async fn test_add_duplicate_task() { let task1 = TaskBuilder::new(1) .with_frequency_once_by_seconds(60) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); let task2 = TaskBuilder::new(1) .with_frequency_once_by_seconds(120) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task1).unwrap(); diff --git a/tests/performance.rs b/tests/performance.rs index 619e465..aa5b4bf 100644 --- a/tests/performance.rs +++ b/tests/performance.rs @@ -23,7 +23,7 @@ async fn test_large_number_of_tasks() { let counter = Arc::new(AtomicU64::new(0)); let task = TaskBuilder::new(i as u64) .with_frequency_once_by_seconds(60) - .spwan_async(CounterTask::new(counter)) + .spawn_async(CounterTask::new(counter)) .unwrap(); timer.add_task(task).unwrap(); } @@ -55,7 +55,7 @@ async fn test_rapid_add_remove_operations() { for i in 0..100 { let task = TaskBuilder::new(i) .with_frequency_once_by_seconds(60) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); diff --git a/tests/task_execution.rs b/tests/task_execution.rs index 77bc03e..8a785b5 100644 --- a/tests/task_execution.rs +++ b/tests/task_execution.rs @@ -22,7 +22,7 @@ async fn test_task_executes_once() { let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(1) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -46,7 +46,7 @@ async fn test_repeated_task() { let task = TaskBuilder::new(1) .with_frequency_repeated_by_seconds(1) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -70,7 +70,7 @@ async fn test_countdown_task() { let task = TaskBuilder::new(1) .with_frequency_count_down_by_seconds(3, 1) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -94,7 +94,7 @@ async fn test_countdown_one_execution() { let task = TaskBuilder::new(1) .with_frequency_count_down_by_seconds(1, 1) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -118,7 +118,7 @@ async fn test_one_second_interval() { let task = TaskBuilder::new(1) .with_frequency_repeated_by_seconds(1) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -144,17 +144,17 @@ async fn test_multiple_tasks_different_frequencies() { let task1 = TaskBuilder::new(1) .with_frequency_repeated_by_seconds(1) - .spwan_async(CounterTask::new(counter1.clone())) + .spawn_async(CounterTask::new(counter1.clone())) .unwrap(); let task2 = TaskBuilder::new(2) .with_frequency_repeated_by_seconds(2) - .spwan_async(CounterTask::new(counter2.clone())) + .spawn_async(CounterTask::new(counter2.clone())) .unwrap(); let task3 = TaskBuilder::new(3) .with_frequency_once_by_seconds(1) - .spwan_async(CounterTask::new(counter3.clone())) + .spawn_async(CounterTask::new(counter3.clone())) .unwrap(); timer.add_task(task1).unwrap(); diff --git a/tests/task_failure.rs b/tests/task_failure.rs index 780ce8c..6a2c985 100644 --- a/tests/task_failure.rs +++ b/tests/task_failure.rs @@ -22,7 +22,7 @@ async fn test_failing_task_does_not_crash_timer() { let task = TaskBuilder::new(1) .with_frequency_repeated_by_seconds(1) - .spwan_async(FailingTask::new(counter.clone())) + .spawn_async(FailingTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); diff --git a/tests/task_management.rs b/tests/task_management.rs index c17ae7f..21d6897 100644 --- a/tests/task_management.rs +++ b/tests/task_management.rs @@ -22,7 +22,7 @@ async fn test_task_add_and_remove() { let task = TaskBuilder::new(100) .with_frequency_once_by_seconds(60) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -47,7 +47,7 @@ async fn test_task_state_query() { let task = TaskBuilder::new(200) .with_frequency_once_by_seconds(10) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -77,13 +77,13 @@ async fn test_task_count() { let task1 = TaskBuilder::new(1) .with_frequency_once_by_seconds(60) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task1).unwrap(); let task2 = TaskBuilder::new(2) .with_frequency_once_by_seconds(120) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task2).unwrap(); @@ -99,13 +99,13 @@ async fn test_get_pending_tasks() { let task1 = TaskBuilder::new(1) .with_frequency_once_by_seconds(60) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task1).unwrap(); let task2 = TaskBuilder::new(2) .with_frequency_once_by_seconds(120) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task2).unwrap(); @@ -126,7 +126,7 @@ async fn test_remove_running_task() { let task = TaskBuilder::new(1) .with_frequency_repeated_by_seconds(1) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -151,7 +151,7 @@ async fn test_get_running_tasks() { let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(1) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); diff --git a/tests/time_wheel_cascade.rs b/tests/time_wheel_cascade.rs index 24d025a..f708518 100644 --- a/tests/time_wheel_cascade.rs +++ b/tests/time_wheel_cascade.rs @@ -23,7 +23,7 @@ async fn test_hour_level_task() { let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(3665) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -48,7 +48,7 @@ async fn test_day_level_task() { let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(90000) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -72,7 +72,7 @@ async fn test_minute_level_repeated_task() { let task = TaskBuilder::new(1) .with_frequency_repeated_by_seconds(60) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -98,7 +98,7 @@ async fn test_hour_level_repeated_task() { let task = TaskBuilder::new(1) .with_frequency_repeated_by_seconds(3600) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -126,7 +126,7 @@ async fn test_minute_to_second_cascade() { let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(65) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -155,7 +155,7 @@ async fn test_hour_level_task_not_execute_early() { let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(3665) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -186,7 +186,7 @@ async fn test_hour_to_minute_to_second_cascade_complete() { // Use 65s instead of 3665s to make test faster while still testing cascade let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(65) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -219,17 +219,17 @@ async fn test_multi_wheel_tasks() { let task_second = TaskBuilder::new(1) .with_frequency_once_by_seconds(2) - .spwan_async(CounterTask::new(counter_second.clone())) + .spawn_async(CounterTask::new(counter_second.clone())) .unwrap(); let task_minute = TaskBuilder::new(2) .with_frequency_once_by_seconds(65) - .spwan_async(CounterTask::new(counter_minute.clone())) + .spawn_async(CounterTask::new(counter_minute.clone())) .unwrap(); let task_hour = TaskBuilder::new(3) .with_frequency_once_by_seconds(3665) - .spwan_async(CounterTask::new(counter_hour.clone())) + .spawn_async(CounterTask::new(counter_hour.clone())) .unwrap(); timer.add_task(task_second).unwrap(); @@ -265,7 +265,7 @@ async fn test_task_placed_in_minute_wheel() { let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(120) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -294,7 +294,7 @@ async fn test_task_placed_in_hour_wheel() { let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(7200) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -318,7 +318,7 @@ async fn test_repeated_task_spanning_wheels() { let task = TaskBuilder::new(1) .with_frequency_repeated_by_seconds(90) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -344,7 +344,7 @@ async fn test_tick_method_works() { let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(2) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); diff --git a/tests/timer_lifecycle.rs b/tests/timer_lifecycle.rs index b1483e1..638e1b4 100644 --- a/tests/timer_lifecycle.rs +++ b/tests/timer_lifecycle.rs @@ -24,7 +24,7 @@ async fn test_timer_start_stop() { let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(60) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -50,7 +50,7 @@ async fn test_timer_stop_functionality() { // Add a task before stopping let task = TaskBuilder::new(1) .with_frequency_repeated_by_seconds(1) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -86,7 +86,7 @@ async fn test_timer_clone() { let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(60) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer.add_task(task).unwrap(); @@ -109,7 +109,7 @@ async fn test_timer_clone_shares_state() { let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(1) - .spwan_async(CounterTask::new(counter.clone())) + .spawn_async(CounterTask::new(counter.clone())) .unwrap(); timer1.add_task(task).unwrap(); From 37f8e9f990340aacc2c3ff41a0cba223f9b4f399 Mon Sep 17 00:00:00 2001 From: chenmch Date: Wed, 4 Mar 2026 14:39:01 +0800 Subject: [PATCH 2/2] update README.md --- README.md | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/README.md b/README.md index fd04e94..daeff2b 100644 --- a/README.md +++ b/README.md @@ -54,7 +54,7 @@ async fn main() { let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(3) - .spwan_async(MyTask { + .spawn_async(MyTask { message: "Hello from MiniTimer!".to_string(), }) .unwrap(); @@ -72,7 +72,7 @@ async fn main() { ```rust let task = TaskBuilder::new(1) .with_frequency_once_by_seconds(60) - .spwan_async(MyTask { ... }) + .spawn_async(MyTask { ... }) .unwrap(); ``` @@ -81,7 +81,7 @@ let task = TaskBuilder::new(1) ```rust let task = TaskBuilder::new(1) .with_frequency_repeated_by_seconds(10) - .spwan_async(MyTask { ... }) + .spawn_async(MyTask { ... }) .unwrap(); ``` @@ -90,7 +90,7 @@ let task = TaskBuilder::new(1) ```rust let task = TaskBuilder::new(1) .with_frequency_count_down_by_seconds(3, 1) - .spwan_async(MyTask { ... }) + .spawn_async(MyTask { ... }) .unwrap(); ``` @@ -100,7 +100,7 @@ let task = TaskBuilder::new(1) let target_timestamp = 1700000000; let task = TaskBuilder::new(1) .with_frequency_once_by_timestamp_seconds(target_timestamp) - .spwan_async(MyTask { ... }) + .spawn_async(MyTask { ... }) .unwrap(); ``` @@ -110,7 +110,7 @@ let task = TaskBuilder::new(1) let task = TaskBuilder::new(1) .with_frequency_repeated_by_seconds(1) .with_max_concurrency(3) - .spwan_async(MyTask { ... }) + .spawn_async(MyTask { ... }) .unwrap(); ```