Searched refs:block_on_stream (Results 1 – 11 of 11) sorted by relevance
| /external/rust/crates/futures/tests/ |
| D | stream_catch_unwind.rs | 3 use futures::executor::block_on_stream; in panic_in_the_middle_of_the_stream()
10 let mut iter = block_on_stream(stream_panicking.catch_unwind()); in panic_in_the_middle_of_the_stream()
19 use futures::executor::block_on_stream; in no_panic()
24 let mut iter = block_on_stream(stream.catch_unwind()); in no_panic()
|
| D | stream_select_all.rs | 33 use futures::executor::block_on_stream; in issue_1626()
39 let mut s = block_on_stream(stream::select_all(vec![a, b])); in issue_1626()
55 use futures::executor::block_on_stream; in works_1()
64 let mut stream = block_on_stream(select_all(streams)); in works_1()
|
| D | future_try_flatten_stream.rs | 3 use futures::executor::block_on_stream; in successful_future()
12 let mut iter = block_on_stream(stream); in successful_future()
22 use futures::executor::block_on_stream; in failed_future()
41 let mut iter = block_on_stream(stream); in failed_future()
|
| D | futures_unordered.rs | 43 use futures::executor::block_on_stream; in works_1()
50 let mut iter = block_on_stream( in works_1()
146 use futures::executor::block_on_stream; in iter_mut_cancel()
161 let mut iter = block_on_stream(stream); in iter_mut_cancel()
203 use futures::executor::block_on_stream; in iter_cancel()
243 let mut iter = block_on_stream(stream); in iter_cancel()
|
| D | buffer_unordered.rs | 5 use futures::executor::{block_on, block_on_stream}; in works()
33 for item in block_on_stream(rx.buffer_unordered(N)) { in works()
|
| D | futures_ordered.rs | 4 use futures::executor::block_on_stream; in works_1()
20 let mut iter = block_on_stream(stream); in works_1()
|
| D | ready_queue.rs | 112 use futures::executor::block_on_stream; in stress()
141 let mut sync = block_on_stream(queue); in stress()
|
| /external/rust/crates/futures/tests_disabled/ |
| D | stream.rs | 1 use futures::executor::{block_on, block_on_stream};
135 let mut s = block_on_stream( in skip_passes_errors_through()
163 let mut s = block_on_stream(iter(vec![Err(1), Err(2), Ok(3), Ok(4), Err(4)]).take(1)); in take_passes_errors_through()
169 let mut s = block_on_stream(iter(vec![Ok(1), Err(2)]).take(1)); in take_passes_errors_through()
181 let mut stream = block_on_stream(list().fuse()); in fuse()
205 let mut rx = block_on_stream(rx); in buffered()
223 let mut rx = block_on_stream(rx); in buffered()
241 let mut rx = block_on_stream(rx); in unordered()
262 let mut rx = block_on_stream(rx); in unordered()
309 assert_eq!(block_on_stream(list()).collect::<Result<Vec<_>, _>>(), in wait()
[all …]
|
| /external/rust/crates/futures-channel/tests/ |
| D | mpsc.rs | 2 use futures::executor::{block_on, block_on_stream};
66 let mut rx = block_on_stream(rx); in send_shared_recv()
355 let mut rx = block_on_stream(rx); in stress_close_receiver_iter()
456 let mut rx = block_on_stream(rx); in try_send_2()
483 let mut rx = block_on_stream(rx); in try_send_fail()
|
| /external/rust/crates/futures-executor/src/ |
| D | lib.rs | 52 pub use crate::local_pool::{block_on, block_on_stream, BlockingStream, LocalPool, LocalSpawner};
|
| D | local_pool.rs | 324 pub fn block_on_stream<S: Stream + Unpin>(stream: S) -> BlockingStream<S> { in block_on_stream() function
|