Lines Matching refs:rx3
902 let (tx3, rx3) = channel::<()>(); in try_recv_states()
914 rx3.recv().unwrap(); in try_recv_states()
918 rx3.recv().unwrap(); in try_recv_states()
1534 let (tx3, rx3) = sync_channel::<()>(1); in try_recv_states()
1546 rx3.recv().unwrap(); in try_recv_states()
1550 rx3.recv().unwrap(); in try_recv_states()
1710 let (_tx3, rx3) = channel::<i32>(); in smoke2()
1717 _foo = rx3.recv() => panic!("3"), in smoke2()
1739 let (tx3, rx3) = channel::<i32>(); in unblocks()
1746 rx3.recv().unwrap(); in unblocks()
1768 let (tx3, rx3) = channel::<()>(); in both_ready()
1776 rx3.recv().unwrap(); in both_ready()
1798 let (tx3, rx3) = channel::<()>(); in stress()
1807 rx3.recv().unwrap(); in stress()
1826 let (tx3, rx3) = channel::<()>(); in cloning()
1829 rx3.recv().unwrap(); in cloning()
1831 assert_eq!(rx3.try_recv(), Err(TryRecvError::Empty)); in cloning()
1833 rx3.recv().unwrap(); in cloning()
1850 let (tx3, rx3) = channel::<()>(); in cloning2()
1853 rx3.recv().unwrap(); in cloning2()
1855 assert_eq!(rx3.try_recv(), Err(TryRecvError::Empty)); in cloning2()
1857 rx3.recv().unwrap(); in cloning2()
1873 let (tx3, rx3) = channel::<()>(); in cloning3()
1887 rx3.recv().unwrap(); in cloning3()