Lines Matching refs:mpsc

15 use std::sync::{mpsc, Arc};
33         let (tx, rx) = mpsc::channel();  in many_oneshot_futures()
69             let (start_tx, mut chain_rx) = tokio::sync::mpsc::channel(10);  in many_multishot_futures()
72                 let (next_tx, next_rx) = tokio::sync::mpsc::channel(10);  in many_multishot_futures()
85             let (final_tx, final_rx) = tokio::sync::mpsc::channel(10);  in many_multishot_futures()
124     let (tx, rx) = mpsc::channel();  in spawn_shutdown()
140 async fn client_server(tx: mpsc::Sender<()>) {  in client_server()
260         let (tx, rx) = mpsc::channel();  in blocking()
307     let (done_tx, done_rx) = mpsc::channel();  in multi_threadpool()
339         let (tx, mut rx) = tokio::sync::mpsc::channel(1024);  in coop_and_block_in_place()
396     let (sync_tx, sync_rx) = std::sync::mpsc::channel::<()>();  in hang_on_shutdown()