Lines Matching refs:rx1
73 let (tx, mut rx1) = broadcast::channel(16); in send_two_recv()
76 assert_empty!(rx1); in send_two_recv()
82 let val = assert_recv!(rx1); in send_two_recv()
88 assert_empty!(rx1); in send_two_recv()
109 let (tx, mut rx1) = broadcast::channel(16); in send_two_recv_bounded()
112 let mut recv1 = task::spawn(rx1.recv()); in send_two_recv_bounded()
130 let mut recv1 = task::spawn(rx1.recv()); in send_two_recv_bounded()
165 let (tx, mut rx1) = broadcast::channel(16); in send_slow_rx()
172 let mut recv1 = task::spawn(rx1.recv()); in send_slow_rx()
188 let val = assert_ready_ok!(task::spawn(rx1.recv()).poll()); in send_slow_rx()
191 let mut recv1 = task::spawn(rx1.recv()); in send_slow_rx()
215 let (tx, mut rx1) = broadcast::channel(16); in drop_rx_while_values_remain()
221 assert_recv!(rx1); in drop_rx_while_values_remain()
225 drop(rx1); in drop_rx_while_values_remain()
230 let (tx, mut rx1) = broadcast::channel(2); in lagging_rx()
236 assert_eq!("one", assert_recv!(rx1)); in lagging_rx()
247 assert_eq!("two", assert_recv!(rx1)); in lagging_rx()
248 assert_eq!("three", assert_recv!(rx1)); in lagging_rx()
320 let (tx, mut rx1) = broadcast::channel::<()>(16); in dropping_tx_notifies_rx()
325 let mut recv1 = task::spawn(rx1.recv()); in dropping_tx_notifies_rx()