Skip to content

Commit

Permalink
docs: fix typos (#6118)
Browse files Browse the repository at this point in the history
  • Loading branch information
fritzrehde authored Oct 30, 2023
1 parent d8a4a5f commit 593dbf5
Show file tree
Hide file tree
Showing 7 changed files with 8 additions and 8 deletions.
2 changes: 1 addition & 1 deletion tokio-util/src/io/stream_reader.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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.)

Expand Down
2 changes: 1 addition & 1 deletion tokio/src/io/interest.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down
2 changes: 1 addition & 1 deletion tokio/src/runtime/scheduler/multi_thread/queue.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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>>(
Expand Down
2 changes: 1 addition & 1 deletion tokio/src/runtime/scheduler/multi_thread/worker.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
2 changes: 1 addition & 1 deletion tokio/src/runtime/scheduler/multi_thread_alt/queue.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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>>(
Expand Down
4 changes: 2 additions & 2 deletions tokio/src/runtime/scheduler/multi_thread_alt/worker.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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)?
}
}
Expand Down Expand Up @@ -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
Expand Down
2 changes: 1 addition & 1 deletion tokio/tests/time_interval.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 593dbf5

Please sign in to comment.