Lines Matching refs:recv1
112 let mut recv1 = task::spawn(rx1.recv()); in send_two_recv_bounded() localVariable
115 assert_pending!(recv1.poll()); in send_two_recv_bounded()
120 assert!(recv1.is_woken()); in send_two_recv_bounded()
123 let val1 = assert_ready_ok!(recv1.poll()); in send_two_recv_bounded()
128 drop((recv1, recv2)); in send_two_recv_bounded()
130 let mut recv1 = task::spawn(rx1.recv()); in send_two_recv_bounded() localVariable
133 assert_pending!(recv1.poll()); in send_two_recv_bounded()
137 assert!(recv1.is_woken()); in send_two_recv_bounded()
140 let val1 = assert_ready_ok!(recv1.poll()); in send_two_recv_bounded()
172 let mut recv1 = task::spawn(rx1.recv()); in send_slow_rx() localVariable
174 assert_pending!(recv1.poll()); in send_slow_rx()
179 assert!(recv1.is_woken()); in send_slow_rx()
184 let val = assert_ready_ok!(recv1.poll()); in send_slow_rx()
191 let mut recv1 = task::spawn(rx1.recv()); in send_slow_rx() localVariable
193 assert_pending!(recv1.poll()); in send_slow_rx()
197 assert!(recv1.is_woken()); in send_slow_rx()
199 let val = assert_ready_ok!(recv1.poll()); in send_slow_rx()
325 let mut recv1 = task::spawn(rx1.recv()); in dropping_tx_notifies_rx() localVariable
328 assert_pending!(recv1.poll()); in dropping_tx_notifies_rx()
333 assert_pending!(recv1.poll()); in dropping_tx_notifies_rx()
338 assert!(recv1.is_woken()); in dropping_tx_notifies_rx()
341 let err = assert_ready_err!(recv1.poll()); in dropping_tx_notifies_rx()