41     let (tx, rx) = oneshot::channel();  in send_recv()
42     let mut rx = task::spawn(rx);  in send_recv()  localVariable
44     assert_pending!(rx.poll());  in send_recv()
48     assert!(rx.is_woken());  in send_recv()
50     let val = assert_ready_ok!(rx.poll());  in send_recv()
56     let (tx, rx) = oneshot::channel();  in async_send_recv()
59     assert_eq!(1, assert_ok!(rx.await));  in async_send_recv()
64     let (tx, rx) = oneshot::channel::<i32>();  in close_tx()
65     let mut rx = task::spawn(rx);  in close_tx()  localVariable
67     assert_pending!(rx.poll());  in close_tx()
71     assert!(rx.is_woken());  in close_tx()
72     assert_ready_err!(rx.poll());  in close_tx()
85     let (tx, rx) = oneshot::channel();  in close_rx()
90     drop(rx);  in close_rx()
102     let (mut tx, rx) = oneshot::channel::<()>();  in async_rx_closed()
105         drop(rx);  in async_rx_closed()
114     let (tx, rx) = oneshot::channel();  in explicit_close_poll()
115     let mut rx = task::spawn(rx);  in explicit_close_poll()  localVariable
119     rx.close();  in explicit_close_poll()
121     let value = assert_ready_ok!(rx.poll());  in explicit_close_poll()
125     let (tx, rx) = oneshot::channel::<i32>();  in explicit_close_poll()
127     let mut rx = task::spawn(rx);  in explicit_close_poll()  localVariable
131     rx.close();  in explicit_close_poll()
138     assert_ready_err!(rx.poll());  in explicit_close_poll()
141     let (tx, rx) = oneshot::channel::<i32>();  in explicit_close_poll()
143     let mut rx = task::spawn(rx);  in explicit_close_poll()  localVariable
147     rx.close();  in explicit_close_poll()
153     assert_ready_err!(rx.poll());  in explicit_close_poll()
159     let (tx, mut rx) = oneshot::channel();  in explicit_close_try_recv()
163     rx.close();  in explicit_close_try_recv()
165     let val = assert_ok!(rx.try_recv());  in explicit_close_try_recv()
169     let (tx, mut rx) = oneshot::channel::<i32>();  in explicit_close_try_recv()
174     rx.close();  in explicit_close_try_recv()
180     assert_err!(rx.try_recv());  in explicit_close_try_recv()
187     let (_tx, rx) = oneshot::channel::<i32>();  in close_try_recv_poll()
188     let mut rx = task::spawn(rx);  in close_try_recv_poll()  localVariable
190     rx.close();  in close_try_recv_poll()
192     assert_err!(rx.try_recv());  in close_try_recv_poll()
194     let _ = rx.poll();  in close_try_recv_poll()
199     let (tx, mut rx) = oneshot::channel::<i32>();  in close_after_recv()
203     assert_eq!(17, rx.try_recv().unwrap());  in close_after_recv()
204     rx.close();  in close_after_recv()
209     let (tx, mut rx) = oneshot::channel::<i32>();  in try_recv_after_completion()
213     assert_eq!(17, rx.try_recv().unwrap());  in try_recv_after_completion()
214     assert_eq!(Err(TryRecvError::Closed), rx.try_recv());  in try_recv_after_completion()
215     rx.close();  in try_recv_after_completion()
220     let (tx, rx) = oneshot::channel::<i32>();  in try_recv_after_completion_await()
221     let mut rx = task::spawn(rx);  in try_recv_after_completion_await()  localVariable
225     assert_eq!(Ok(17), assert_ready!(rx.poll()));  in try_recv_after_completion_await()
226     assert_eq!(Err(TryRecvError::Closed), rx.try_recv());  in try_recv_after_completion_await()
227     rx.close();  in try_recv_after_completion_await()
232     let (mut tx, mut rx) = oneshot::channel::<i32>();  in drops_tasks()
237     assert_pending!(rx_task.enter(|cx, _| Pin::new(&mut rx).poll(cx)));  in drops_tasks()
240     drop(rx);  in drops_tasks()
248     let (tx, mut rx) = oneshot::channel();  in receiver_changes_task()
253     assert_pending!(task1.enter(|cx, _| Pin::new(&mut rx).poll(cx)));  in receiver_changes_task()
258     assert_pending!(task2.enter(|cx, _| Pin::new(&mut rx).poll(cx)));  in receiver_changes_task()
268     assert_ready_ok!(task2.enter(|cx, _| Pin::new(&mut rx).poll(cx)));  in receiver_changes_task()
273     let (mut tx, rx) = oneshot::channel::<i32>();  in sender_changes_task()
288     drop(rx);  in sender_changes_task()