Lines Matching refs:rx
11 let (mut tx, rx) = oneshot::channel::<u32>(); in smoke_poll()
12 let mut rx = Some(rx); in smoke_poll() localVariable
16 drop(rx.take()); in smoke_poll()
27 let (mut tx, rx) = oneshot::channel::<u32>(); in cancel_notifies()
32 drop(rx); in cancel_notifies()
40 let (tx, rx) = mpsc::channel::<(Sender<_>, mpsc::Sender<_>)>(); in cancel_lots()
42 for (mut tx, tx2) in rx { in cancel_lots()
62 let (mut tx, rx) = oneshot::channel::<u32>(); in cancel_after_sender_drop_doesnt_notify()
66 drop(rx); in cancel_after_sender_drop_doesnt_notify()
71 let (mut tx, mut rx) = oneshot::channel::<u32>(); in close()
72 rx.close(); in close()
74 match rx.poll_unpin(cx) { in close()
85 let (mut tx, mut rx) = oneshot::channel::<u32>(); in close_wakes()
88 rx.close(); in close_wakes()
98 let (tx, rx) = oneshot::channel::<u32>(); in is_canceled()
100 drop(rx); in is_canceled()
108 let (tx, rx) = mpsc::channel::<Sender<_>>(); in cancel_sends()
110 for otx in rx { in cancel_sends()