File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -106,7 +106,7 @@ where
106
106
cx : & mut Context < ' _ > ,
107
107
) -> Poll < Option < Self :: Item > > {
108
108
// First up, try to spawn off as many futures as possible by filling up
109
- // our slab of futures.
109
+ // our queue of futures.
110
110
while self . in_progress_queue . len ( ) < self . max {
111
111
match self . as_mut ( ) . stream ( ) . poll_next ( cx) {
112
112
Poll :: Ready ( Some ( fut) ) => self . as_mut ( ) . in_progress_queue ( ) . push ( fut) ,
Original file line number Diff line number Diff line change @@ -84,7 +84,7 @@ impl<St> Stream for TryBufferUnordered<St>
84
84
cx : & mut Context < ' _ > ,
85
85
) -> Poll < Option < Self :: Item > > {
86
86
// First up, try to spawn off as many futures as possible by filling up
87
- // our slab of futures. Propagate errors from the stream immediately.
87
+ // our queue of futures. Propagate errors from the stream immediately.
88
88
while self . in_progress_queue . len ( ) < self . max {
89
89
match self . as_mut ( ) . stream ( ) . poll_next ( cx) ? {
90
90
Poll :: Ready ( Some ( fut) ) => self . as_mut ( ) . in_progress_queue ( ) . push ( fut. into_future ( ) ) ,
You can’t perform that action at this time.
0 commit comments