Skip to content

Fix typo: spwan_async -> spawn_async #12

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
Curricane merged 2 commits into from
Mar 4, 2026
Merged

Fix typo: spwan_async -> spawn_async #12

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
e1b6527
Fix typo: spwan_async -> spawn_async
Mar 4, 2026
37f8e9f
update README.md
Mar 4, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 6 additions & 6 deletions README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand All @@ -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();
```

Expand All @@ -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();
```

Expand All @@ -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();
```

Expand All @@ -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();
```

Expand All @@ -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();
```

Expand Down
4 changes: 2 additions & 2 deletions examples/advance_task.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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(),
})
Expand Down Expand Up @@ -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(),
})
Expand Down
2 changes: 1 addition & 1 deletion examples/concurrency_control.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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(),
})
Expand Down
2 changes: 1 addition & 1 deletion examples/countdown_task.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand Down
2 changes: 1 addition & 1 deletion examples/once_delayed_task.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand Down
2 changes: 1 addition & 1 deletion examples/repeated_task.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand Down
6 changes: 3 additions & 3 deletions examples/task_management.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand Down
2 changes: 1 addition & 1 deletion src/task/task.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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<T: TaskRunner<Output = ()> + Send + Sync>(
pub fn spawn_async<T: TaskRunner<Output = ()> + Send + Sync>(
self,
task_runner: T,
) -> Result<Task, TaskError> {
Expand Down
20 changes: 10 additions & 10 deletions src/timer/wheel.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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);

Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -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
Expand All @@ -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
Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -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();
Expand All @@ -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();
Expand All @@ -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();
Expand Down Expand Up @@ -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();
Expand Down
18 changes: 9 additions & 9 deletions tests/advance_task.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand Down Expand Up @@ -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();
Expand Down Expand Up @@ -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();
Expand Down Expand Up @@ -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();
Expand Down Expand Up @@ -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();
Expand Down Expand Up @@ -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();
Expand Down Expand Up @@ -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();
Expand Down Expand Up @@ -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();
Expand Down Expand Up @@ -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();
Expand Down
8 changes: 4 additions & 4 deletions tests/concurrency_boundary.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand Down Expand Up @@ -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();
Expand All @@ -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();
Expand All @@ -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();
Expand Down
4 changes: 2 additions & 2 deletions tests/error_handling.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand Down
4 changes: 2 additions & 2 deletions tests/performance.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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();
}
Expand Down Expand Up @@ -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();

Expand Down
Loading