diff options
Diffstat (limited to 'src/stream/try_stream/try_buffered.rs')
| -rw-r--r-- | src/stream/try_stream/try_buffered.rs | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/stream/try_stream/try_buffered.rs b/src/stream/try_stream/try_buffered.rs index 45bd3f8..9f48e5c 100644 --- a/src/stream/try_stream/try_buffered.rs +++ b/src/stream/try_stream/try_buffered.rs @@ -54,7 +54,7 @@ where // our queue of futures. Propagate errors from the stream immediately. 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.into_future()), + Poll::Ready(Some(fut)) => this.in_progress_queue.push_back(fut.into_future()), Poll::Ready(None) | Poll::Pending => break, } } |