Searched refs:mpsc_stream (Results 1 – 3 of 3) sorted by relevance
11 pub(crate) mod mpsc_stream; module172 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()
12 pub(crate) mod mpsc_stream; module65 let (tx, rx) = support::mpsc_stream::unbounded_channel_stream::<()>(); in no_extra_poll()
17 pub(crate) mod mpsc_stream; module89 let (tx, rx) = support::mpsc_stream::channel_stream::<i32>(16); in send_recv_stream_with_buffer()188 let (tx, rx) = support::mpsc_stream::unbounded_channel_stream::<i32>(); in send_recv_stream_unbounded()