docs: fix typos (#6118)

Author: fritzrehde

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.)
 

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.

tokio/src/runtime/scheduler/multi_thread/queue.rs

@@ -179,7 +179,7 @@ impl<T> Local<T> {
     /// 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<O: Overflow<T>>(

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

tokio/src/runtime/scheduler/multi_thread_alt/queue.rs

@@ -163,7 +163,7 @@ impl<T> Local<T> {
     /// 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<O: Overflow<T>>(

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

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