File tree 2 files changed +1
-3
lines changed
2 files changed +1
-3
lines changed Original file line number Diff line number Diff line change 53
53
loop {
54
54
if let Some ( inner) = this. inner_stream . as_mut ( ) . as_pin_mut ( ) {
55
55
match futures_core:: ready!( inner. poll_next( cx) ) {
56
- item @ Some ( _) => return Poll :: Ready ( next_item ) ,
56
+ item @ Some ( _) => return Poll :: Ready ( item ) ,
57
57
None => this. inner_stream . set ( None ) ,
58
58
}
59
59
}
Original file line number Diff line number Diff line change @@ -154,7 +154,6 @@ impl Stream for Interchanger {
154
154
}
155
155
}
156
156
157
- // https://github.com/async-rs/async-std/pull/701
158
157
#[ test]
159
158
fn flat_map_doesnt_poll_completed_inner_stream ( ) {
160
159
task:: block_on ( async {
@@ -169,7 +168,6 @@ fn flat_map_doesnt_poll_completed_inner_stream() {
169
168
} ) ;
170
169
}
171
170
172
- // https://github.com/async-rs/async-std/pull/701
173
171
#[ test]
174
172
fn flatten_doesnt_poll_completed_inner_stream ( ) {
175
173
task:: block_on ( async {
You can’t perform that action at this time.
0 commit comments