diff --git a/tokio-util/src/io/stream_reader.rs b/tokio-util/src/io/stream_reader.rs index 6ecf8ec989d..096c96f301a 100644 --- a/tokio-util/src/io/stream_reader.rs +++ b/tokio-util/src/io/stream_reader.rs @@ -302,7 +302,7 @@ where } // The code below is a manual expansion of the code that pin-project-lite would -// generate. This is done because pin-project-lite fails by hitting the recusion +// generate. This is done because pin-project-lite fails by hitting the recursion // limit on this struct. (Every line of documentation is handled recursively by // the macro.) diff --git a/tokio/src/io/interest.rs b/tokio/src/io/interest.rs index 3879e9ba089..e8cc0c42d84 100644 --- a/tokio/src/io/interest.rs +++ b/tokio/src/io/interest.rs @@ -239,7 +239,7 @@ impl Interest { if self.is_error() { // There is no error interest in mio, because error events are always reported. - // But mio interests cannot be empty and an interest is needed just for the registeration. + // But mio interests cannot be empty and an interest is needed just for the registration. // // read readiness is filtered out in `Interest::mask` or `Ready::from_interest` if // the read interest was not specified by the user. diff --git a/tokio/src/runtime/scheduler/multi_thread/queue.rs b/tokio/src/runtime/scheduler/multi_thread/queue.rs index 41121a370f9..e3a3105bbb6 100644 --- a/tokio/src/runtime/scheduler/multi_thread/queue.rs +++ b/tokio/src/runtime/scheduler/multi_thread/queue.rs @@ -179,7 +179,7 @@ impl Local { /// Pushes a task to the back of the local queue, if there is not enough /// capacity in the queue, this triggers the overflow operation. /// - /// When the queue overflows, half of the curent contents of the queue is + /// When the queue overflows, half of the current contents of the queue is /// moved to the given Injection queue. This frees up capacity for more /// tasks to be pushed into the local queue. pub(crate) fn push_back_or_overflow>( diff --git a/tokio/src/runtime/scheduler/multi_thread/worker.rs b/tokio/src/runtime/scheduler/multi_thread/worker.rs index 22c3e739f43..d91c641c4f3 100644 --- a/tokio/src/runtime/scheduler/multi_thread/worker.rs +++ b/tokio/src/runtime/scheduler/multi_thread/worker.rs @@ -795,7 +795,7 @@ impl Core { // safety: passing in the correct `inject::Synced`. let mut tasks = unsafe { worker.inject().pop_n(&mut synced.inject, n) }; - // Pop the first task to return immedietly + // Pop the first task to return immediately let ret = tasks.next(); // Push the rest of the on the run queue diff --git a/tokio/src/runtime/scheduler/multi_thread_alt/queue.rs b/tokio/src/runtime/scheduler/multi_thread_alt/queue.rs index e41e9fdb3a6..004715daec8 100644 --- a/tokio/src/runtime/scheduler/multi_thread_alt/queue.rs +++ b/tokio/src/runtime/scheduler/multi_thread_alt/queue.rs @@ -163,7 +163,7 @@ impl Local { /// Pushes a task to the back of the local queue, if there is not enough /// capacity in the queue, this triggers the overflow operation. /// - /// When the queue overflows, half of the curent contents of the queue is + /// When the queue overflows, half of the current contents of the queue is /// moved to the given Injection queue. This frees up capacity for more /// tasks to be pushed into the local queue. pub(crate) fn push_back_or_overflow>( diff --git a/tokio/src/runtime/scheduler/multi_thread_alt/worker.rs b/tokio/src/runtime/scheduler/multi_thread_alt/worker.rs index c9a05557a40..66865f59753 100644 --- a/tokio/src/runtime/scheduler/multi_thread_alt/worker.rs +++ b/tokio/src/runtime/scheduler/multi_thread_alt/worker.rs @@ -563,7 +563,7 @@ impl Worker { let maybe_task = cx.shared().next_remote_task_synced(&mut synced); (maybe_task, core) } else { - // block the thread to wait for a core to be assinged to us + // block the thread to wait for a core to be assigned to us self.wait_for_core(cx, synced)? } } @@ -801,7 +801,7 @@ impl Worker { // safety: passing in the correct `inject::Synced`. let mut tasks = unsafe { cx.shared().inject.pop_n(&mut synced.inject, n) }; - // Pop the first task to return immedietly + // Pop the first task to return immediately let ret = tasks.next(); // Push the rest of the on the run queue diff --git a/tokio/tests/time_interval.rs b/tokio/tests/time_interval.rs index 9b7a6fdd6df..4f3e95b0d2a 100644 --- a/tokio/tests/time_interval.rs +++ b/tokio/tests/time_interval.rs @@ -205,7 +205,7 @@ async fn reset() { } #[tokio::test(start_paused = true)] -async fn reset_immediatelly() { +async fn reset_immediately() { let start = Instant::now(); // This is necessary because the timer is only so granular, and in order for