diff --git a/benches/copy.rs b/benches/copy.rs index 5f91f315e..12d4531f0 100644 --- a/benches/copy.rs +++ b/benches/copy.rs @@ -73,7 +73,7 @@ impl SlowHddWriter { fn write_bytes( mut self: std::pin::Pin<&mut Self>, cx: &mut std::task::Context<'_>, - writeable: usize, + writable: usize, ) -> std::task::Poll> { let service_res = self.as_mut().service_write(cx); @@ -86,7 +86,7 @@ impl SlowHddWriter { assert!(service_res.is_pending()); Poll::Pending } else { - let written = available.min(writeable); + let written = available.min(writable); self.buffer_used += written; Poll::Ready(Ok(written)) } @@ -123,8 +123,8 @@ impl AsyncWrite for SlowHddWriter { cx: &mut std::task::Context<'_>, bufs: &[std::io::IoSlice<'_>], ) -> std::task::Poll> { - let writeable = bufs.iter().fold(0, |acc, buf| acc + buf.len()); - self.write_bytes(cx, writeable) + let writable = bufs.iter().fold(0, |acc, buf| acc + buf.len()); + self.write_bytes(cx, writable) } fn is_write_vectored(&self) -> bool { diff --git a/tokio-util/src/io/write_all_vectored.rs b/tokio-util/src/io/write_all_vectored.rs index c2b19a19c..df9a3a500 100644 --- a/tokio-util/src/io/write_all_vectored.rs +++ b/tokio-util/src/io/write_all_vectored.rs @@ -148,7 +148,7 @@ fn advance_slices<'a>(bufs: &mut &mut [IoSlice<'a>], n: usize) { *bufs = &mut std::mem::take(bufs)[remove..]; if let Some(first) = bufs.first_mut() { let buf = &first[left..]; - // necessary due to limitating in the borrow checker, + // Necessary due to a limitation in the borrow checker, // when tokio MSRV reaches 1.81.0 this entire function // can be replaced with `IoSlice::advance_slices` // diff --git a/tokio/tests/rt_threaded.rs b/tokio/tests/rt_threaded.rs index ffd79f3e9..b23daaeda 100644 --- a/tokio/tests/rt_threaded.rs +++ b/tokio/tests/rt_threaded.rs @@ -700,7 +700,7 @@ fn wake_deferred_tasks_before_block_in_place() { let (tx2, rx2) = oneshot::channel::<()>(); let deferred_task = tokio_test::task::spawn(tokio::task::yield_now()); - let deffered_task = Arc::new(Mutex::new(deferred_task)); + let deferred_task = Arc::new(Mutex::new(deferred_task)); let rt = runtime::Builder::new_multi_thread() .worker_threads(1) @@ -708,7 +708,7 @@ fn wake_deferred_tasks_before_block_in_place() { .unwrap(); let jh = { - let deferred_task = Arc::clone(&deffered_task); + let deferred_task = Arc::clone(&deferred_task); rt.spawn(async move { { let mut lock = deferred_task.lock().unwrap(); @@ -728,7 +728,7 @@ fn wake_deferred_tasks_before_block_in_place() { // check that the deferred task was woken before the `block_in_place` ends let is_woken = { - let lock = deffered_task.lock().unwrap(); + let lock = deferred_task.lock().unwrap(); lock.is_woken() };