Searched refs:unbounded_channel_stream (Results 1 – 9 of 9) sorted by relevance
| /external/rust/android-crates-io/crates/tokio-stream/tests/ |
| D | stream_collect.rs | 45 let (tx, rx) = mpsc::unbounded_channel_stream(); in collect_vec_items()
66 let (tx, rx) = mpsc::unbounded_channel_stream(); in collect_string_items()
88 let (tx, rx) = mpsc::unbounded_channel_stream(); in collect_str_items()
110 let (tx, rx) = mpsc::unbounded_channel_stream(); in collect_results_ok()
132 let (tx, rx) = mpsc::unbounded_channel_stream(); in collect_results_err()
|
| D | stream_merge.rs | 26 let (tx1, rx1) = mpsc::unbounded_channel_stream(); in merge_async_streams()
27 let (tx2, rx2) = mpsc::unbounded_channel_stream(); in merge_async_streams()
|
| D | stream_stream_map.rs | 49 let (tx, rx) = mpsc::unbounded_channel_stream(); in single_entry()
88 let (tx1, rx1) = mpsc::unbounded_channel_stream(); in multiple_entries()
89 let (tx2, rx2) = mpsc::unbounded_channel_stream(); in multiple_entries()
147 let (tx, rx) = mpsc::unbounded_channel_stream(); in insert_remove()
177 let (tx1, rx1) = mpsc::unbounded_channel_stream(); in replace()
178 let (tx2, rx2) = mpsc::unbounded_channel_stream(); in replace()
|
| D | stream_chain.rs | 54 let (tx1, rx1) = mpsc::unbounded_channel_stream(); in pending_first()
55 let (tx2, rx2) = mpsc::unbounded_channel_stream(); in pending_first()
|
| /external/rust/android-crates-io/crates/tokio-stream/tests/support/ |
| D | mpsc.rs | 5 pub fn unbounded_channel_stream<T: Unpin>() -> (UnboundedSender<T>, impl Stream<Item = T>) { in unbounded_channel_stream() function
|
| /external/rust/android-crates-io/crates/tokio/tests/support/ |
| D | mpsc_stream.rs | 18 pub fn unbounded_channel_stream<T: Unpin>() -> (UnboundedSender<T>, impl Stream<Item = T>) { in unbounded_channel_stream() function
|
| /external/rust/android-crates-io/crates/tokio/tests/ |
| D | task_blocking.rs | 172 let (tx, rx) = support::mpsc_stream::unbounded_channel_stream(); in coop_disabled_in_block_in_place()
203 let (tx, rx) = support::mpsc_stream::unbounded_channel_stream(); in coop_disabled_in_block_in_place_in_block_on()
|
| D | rt_basic.rs | 80 let (tx, rx) = support::mpsc_stream::unbounded_channel_stream::<()>(); in no_extra_poll()
|
| D | sync_mpsc.rs | 381 let (tx, rx) = support::mpsc_stream::unbounded_channel_stream::<i32>(); in send_recv_stream_unbounded()
|