Lines Matching refs:rx
38 let (tx, rx) = oneshot::channel(); in send_recv()
39 let mut rx = task::spawn(rx); in send_recv() localVariable
41 assert_pending!(rx.poll()); in send_recv()
45 assert!(rx.is_woken()); in send_recv()
47 let val = assert_ready_ok!(rx.poll()); in send_recv()
53 let (tx, rx) = oneshot::channel(); in async_send_recv()
56 assert_eq!(1, assert_ok!(rx.await)); in async_send_recv()
61 let (tx, rx) = oneshot::channel::<i32>(); in close_tx()
62 let mut rx = task::spawn(rx); in close_tx() localVariable
64 assert_pending!(rx.poll()); in close_tx()
68 assert!(rx.is_woken()); in close_tx()
69 assert_ready_err!(rx.poll()); in close_tx()
82 let (tx, rx) = oneshot::channel(); in close_rx()
87 drop(rx); in close_rx()
99 let (mut tx, rx) = oneshot::channel::<()>(); in async_rx_closed()
102 drop(rx); in async_rx_closed()
111 let (tx, rx) = oneshot::channel(); in explicit_close_poll()
112 let mut rx = task::spawn(rx); in explicit_close_poll() localVariable
116 rx.close(); in explicit_close_poll()
118 let value = assert_ready_ok!(rx.poll()); in explicit_close_poll()
122 let (tx, rx) = oneshot::channel::<i32>(); in explicit_close_poll()
124 let mut rx = task::spawn(rx); in explicit_close_poll() localVariable
128 rx.close(); in explicit_close_poll()
135 assert_ready_err!(rx.poll()); in explicit_close_poll()
138 let (tx, rx) = oneshot::channel::<i32>(); in explicit_close_poll()
140 let mut rx = task::spawn(rx); in explicit_close_poll() localVariable
144 rx.close(); in explicit_close_poll()
150 assert_ready_err!(rx.poll()); in explicit_close_poll()
156 let (tx, mut rx) = oneshot::channel(); in explicit_close_try_recv()
160 rx.close(); in explicit_close_try_recv()
162 let val = assert_ok!(rx.try_recv()); in explicit_close_try_recv()
166 let (tx, mut rx) = oneshot::channel::<i32>(); in explicit_close_try_recv()
171 rx.close(); in explicit_close_try_recv()
177 assert_err!(rx.try_recv()); in explicit_close_try_recv()
184 let (_tx, rx) = oneshot::channel::<i32>(); in close_try_recv_poll()
185 let mut rx = task::spawn(rx); in close_try_recv_poll() localVariable
187 rx.close(); in close_try_recv_poll()
189 assert_err!(rx.try_recv()); in close_try_recv_poll()
191 let _ = rx.poll(); in close_try_recv_poll()
196 let (tx, mut rx) = oneshot::channel::<i32>(); in close_after_recv()
200 assert_eq!(17, rx.try_recv().unwrap()); in close_after_recv()
201 rx.close(); in close_after_recv()
206 let (tx, mut rx) = oneshot::channel::<i32>(); in try_recv_after_completion()
210 assert_eq!(17, rx.try_recv().unwrap()); in try_recv_after_completion()
211 assert_eq!(Err(TryRecvError::Closed), rx.try_recv()); in try_recv_after_completion()
212 rx.close(); in try_recv_after_completion()
217 let (tx, rx) = oneshot::channel::<i32>(); in try_recv_after_completion_await()
218 let mut rx = task::spawn(rx); in try_recv_after_completion_await() localVariable
222 assert_eq!(Ok(17), assert_ready!(rx.poll())); in try_recv_after_completion_await()
223 assert_eq!(Err(TryRecvError::Closed), rx.try_recv()); in try_recv_after_completion_await()
224 rx.close(); in try_recv_after_completion_await()
229 let (mut tx, mut rx) = oneshot::channel::<i32>(); in drops_tasks()
234 assert_pending!(rx_task.enter(|cx, _| Pin::new(&mut rx).poll(cx))); in drops_tasks()
237 drop(rx); in drops_tasks()
245 let (tx, mut rx) = oneshot::channel(); in receiver_changes_task()
250 assert_pending!(task1.enter(|cx, _| Pin::new(&mut rx).poll(cx))); in receiver_changes_task()
255 assert_pending!(task2.enter(|cx, _| Pin::new(&mut rx).poll(cx))); in receiver_changes_task()
265 assert_ready_ok!(task2.enter(|cx, _| Pin::new(&mut rx).poll(cx))); in receiver_changes_task()
270 let (mut tx, rx) = oneshot::channel::<i32>(); in sender_changes_task()
285 drop(rx); in sender_changes_task()