Searched refs:done_tx (Results 1 – 5 of 5) sorted by relevance
172 let (done_tx, done_rx) = oneshot::channel(); in blocking_and_regular_inner()173 let done_tx = AtomicOneshot::new(done_tx); in blocking_and_regular_inner() localVariable186 let done_tx = done_tx.clone(); in blocking_and_regular_inner() localVariable190 done_tx.assert_send(()); in blocking_and_regular_inner()267 let (done_tx, done_rx) = oneshot::channel::<()>(); in shutdown_with_notification()282 let _ = done_tx.send(()); in shutdown_with_notification()319 let (done_tx, done_rx) = oneshot::channel(); in pool_multi_notify()320 let done_tx1 = AtomicOneshot::new(done_tx); in pool_multi_notify()
199 let (done_tx, mut done_rx) = mpsc::unbounded_channel();204 let done_tx = done_tx.clone(); localVariable209 assert_ok!(done_tx.send(msg));216 drop(done_tx);251 let (done_tx, mut done_rx) = mpsc::unbounded_channel();256 let done_tx = done_tx.clone(); localVariable261 assert_ok!(done_tx.send(msg));268 drop(done_tx);
199 let (done_tx, done_rx) = std::sync::mpsc::channel(); in coop_disabled_in_block_in_place_in_block_on()200 let done = done_tx.clone(); in coop_disabled_in_block_in_place_in_block_on()225 let _ = done_tx.send(Err("timed out (probably hanging)")); in coop_disabled_in_block_in_place_in_block_on()
349 let (done_tx, done_rx) = mpsc::channel(); in multi_threadpool()353 done_tx.send(()).unwrap(); in multi_threadpool()
367 let (done_tx, done_rx) = std::sync::mpsc::channel(); in with_timeout()373 done_tx.send(()).unwrap(); in with_timeout()