|
|
@ -154,7 +154,6 @@ impl Stream for Interchanger {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// https://github.com/async-rs/async-std/pull/701
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
#[test]
|
|
|
|
fn flat_map_doesnt_poll_completed_inner_stream() {
|
|
|
|
fn flat_map_doesnt_poll_completed_inner_stream() {
|
|
|
|
task::block_on(async {
|
|
|
|
task::block_on(async {
|
|
|
@ -169,7 +168,6 @@ fn flat_map_doesnt_poll_completed_inner_stream() {
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// https://github.com/async-rs/async-std/pull/701
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
#[test]
|
|
|
|
fn flatten_doesnt_poll_completed_inner_stream() {
|
|
|
|
fn flatten_doesnt_poll_completed_inner_stream() {
|
|
|
|
task::block_on(async {
|
|
|
|
task::block_on(async {
|
|
|
|