diff options
Diffstat (limited to 'src/stream/stream/buffered.rs')
| -rw-r--r-- | src/stream/stream/buffered.rs | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/stream/stream/buffered.rs b/src/stream/stream/buffered.rs index 6052a73..8ca0391 100644 --- a/src/stream/stream/buffered.rs +++ b/src/stream/stream/buffered.rs @@ -64,7 +64,7 @@ where // our queue of futures. while this.in_progress_queue.len() < *this.max { match this.stream.as_mut().poll_next(cx) { - Poll::Ready(Some(fut)) => this.in_progress_queue.push(fut), + Poll::Ready(Some(fut)) => this.in_progress_queue.push_back(fut), Poll::Ready(None) | Poll::Pending => break, } } |