rename to_go to remaining

tokio-rs · Oct 4, 2023 · 5b95665 · 5b95665
1 parent 14083e8
commit 5b95665
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/tokio/src/sync/mpsc/chan.rs b/tokio/src/sync/mpsc/chan.rs
@@ -307,7 +307,7 @@ impl<T, S: Semaphore> Rx<T, S> {
  ) -> Poll<usize> {
  use super::block::Read;
 
- let mut to_go = if limit > 0 { limit } else { super::BLOCK_CAP };
+ let mut remaining = if limit > 0 { limit } else { super::BLOCK_CAP };
  let initial_length = buffer.len();
 
  ready!(crate::trace::trace_leaf(cx));
@@ -318,10 +318,10 @@ impl<T, S: Semaphore> Rx<T, S> {
  let rx_fields = unsafe { &mut *rx_fields_ptr };
  macro_rules! try_recv {
  () => {
- while (to_go > 0) {
+ while (remaining > 0) {
  match rx_fields.list.pop(&self.inner.tx) {
  Some(Read::Value(value)) => {
- to_go = to_go - 1;
+ remaining -= 1;
  buffer.push(value);
  }