Lines Matching refs:oneshot
3 use futures::channel::oneshot; in works_1()
8 let (a_tx, a_rx) = oneshot::channel::<i32>(); in works_1()
9 let (b_tx, b_rx) = oneshot::channel::<i32>(); in works_1()
10 let (c_tx, c_rx) = oneshot::channel::<i32>(); in works_1()
29 use futures::channel::oneshot; in works_2()
34 let (a_tx, a_rx) = oneshot::channel::<i32>(); in works_2()
35 let (b_tx, b_rx) = oneshot::channel::<i32>(); in works_2()
36 let (c_tx, c_rx) = oneshot::channel::<i32>(); in works_2()
69 use futures::channel::oneshot; in queue_never_unblocked()
75 let (_a_tx, a_rx) = oneshot::channel::<Box<dyn Any + Send>>(); in queue_never_unblocked()
76 let (b_tx, b_rx) = oneshot::channel::<Box<dyn Any + Send>>(); in queue_never_unblocked()
77 let (c_tx, c_rx) = oneshot::channel::<Box<dyn Any + Send>>(); in queue_never_unblocked()