11     let (mut tx, rx) = oneshot::channel::<u32>();  in smoke_poll()
14         assert!(tx.poll_canceled(cx).is_pending());  in smoke_poll()
15         assert!(tx.poll_canceled(cx).is_pending());  in smoke_poll()
17         assert!(tx.poll_canceled(cx).is_ready());  in smoke_poll()
18         assert!(tx.poll_canceled(cx).is_ready());  in smoke_poll()
27     let (mut tx, rx) = oneshot::channel::<u32>();  in cancel_notifies()
30         block_on(tx.cancellation());  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()
43             block_on(tx.cancellation());  in cancel_lots()
51         tx.send((otx, tx2)).unwrap();  in cancel_lots()
55     drop(tx);  in cancel_lots()
62     let (mut tx, rx) = oneshot::channel::<u32>();  in cancel_after_sender_drop_doesnt_notify()
64     assert_eq!(tx.poll_canceled(&mut cx), Poll::Pending);  in cancel_after_sender_drop_doesnt_notify()
65     drop(tx);  in cancel_after_sender_drop_doesnt_notify()
71     let (mut tx, mut rx) = oneshot::channel::<u32>();  in close()
78         assert!(tx.poll_canceled(cx).is_ready());  in close()
85     let (mut tx, mut rx) = oneshot::channel::<u32>();  in close_wakes()
91     block_on(tx.cancellation());  in close_wakes()
98     let (tx, rx) = oneshot::channel::<u32>();  in is_canceled()
99     assert!(!tx.is_canceled());  in is_canceled()
101     assert!(tx.is_canceled());  in is_canceled()
108     let (tx, rx) = mpsc::channel::<Sender<_>>();  in cancel_sends()
117         tx.send(otx).unwrap();  in cancel_sends()
123     drop(tx);  in cancel_sends()