diff --git a/src/lib.rs b/src/lib.rs index ee1fe2c..4660a5b 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -175,7 +175,7 @@ impl AsyncSender { if internal.send_count == 0 { return Err(Error::Closed); } - if let Some(first) = internal.recv_wait.pop_front() { + if let Some(first) = internal.next_recv() { drop(internal); unsafe { first.send(data) } Ok(())