Lines Matching refs:rx1
364 let (tx1, rx1) = channel::<()>(); in send_from_outside_runtime()
372 rx1.recv().unwrap(); in send_from_outside_runtime()
398 let (tx1, rx1) = channel::<i32>(); in no_runtime()
401 assert_eq!(rx1.recv().unwrap(), 1); in no_runtime()
900 let (tx1, rx1) = channel::<i32>(); in try_recv_states()
912 assert_eq!(rx1.try_recv(), Err(TryRecvError::Empty)); in try_recv_states()
915 assert_eq!(rx1.try_recv(), Ok(1)); in try_recv_states()
916 assert_eq!(rx1.try_recv(), Err(TryRecvError::Empty)); in try_recv_states()
919 assert_eq!(rx1.try_recv(), Err(TryRecvError::Disconnected)); in try_recv_states()
1532 let (tx1, rx1) = sync_channel::<i32>(1); in try_recv_states()
1544 assert_eq!(rx1.try_recv(), Err(TryRecvError::Empty)); in try_recv_states()
1547 assert_eq!(rx1.try_recv(), Ok(1)); in try_recv_states()
1548 assert_eq!(rx1.try_recv(), Err(TryRecvError::Empty)); in try_recv_states()
1551 assert_eq!(rx1.try_recv(), Err(TryRecvError::Disconnected)); in try_recv_states()
1657 let (tx1, rx1) = sync_channel::<()>(3); in issue_15761()
1661 rx1.recv().unwrap(); in issue_15761()
1683 let (tx1, rx1) = channel::<i32>(); in smoke()
1687 foo = rx1.recv() => assert_eq!(foo.unwrap(), 1), in smoke()
1692 _foo = rx1.recv() => panic!(), in smoke()
1697 foo = rx1.recv() => assert!(foo.is_err()), in smoke()
1708 let (_tx1, rx1) = channel::<i32>(); in smoke2()
1715 _foo = rx1.recv() => panic!("1"), in smoke2()
1725 let (_tx1, rx1) = channel::<i32>(); in closed()
1730 _a1 = rx1.recv() => panic!(), in closed()
1737 let (tx1, rx1) = channel::<i32>(); in unblocks()
1753 a = rx1.recv() => assert_eq!(a.unwrap(), 1), in unblocks()
1758 a = rx1.recv() => assert!(a.is_err()), in unblocks()
1766 let (tx1, rx1) = channel::<i32>(); in both_ready()
1780 a = rx1.recv() => { assert_eq!(a.unwrap(), 1); }, in both_ready()
1784 a = rx1.recv() => { assert_eq!(a.unwrap(), 1); }, in both_ready()
1787 assert_eq!(rx1.try_recv(), Err(TryRecvError::Empty)); in both_ready()
1796 let (tx1, rx1) = channel::<i32>(); in stress()
1813 i1 = rx1.recv() => { assert!(i % 2 == 0 && i == i1.unwrap()); }, in stress()
1824 let (tx1, rx1) = channel::<i32>(); in cloning()
1838 _i1 = rx1.recv() => {}, in cloning()
1848 let (tx1, rx1) = channel::<i32>(); in cloning2()
1862 _i1 = rx1.recv() => {}, in cloning2()
1871 let (tx1, rx1) = channel::<()>(); in cloning3()
1876 _ = rx1.recv() => panic!(), in cloning3()
1983 let (tx1, rx1) = channel(); in oneshot_data_waiting()
1987 _n = rx1.recv() => {} in oneshot_data_waiting()
2002 let (tx1, rx1) = channel(); in stream_data_waiting()
2006 rx1.recv().unwrap(); in stream_data_waiting()
2007 rx1.recv().unwrap(); in stream_data_waiting()
2010 _n = rx1.recv() => {} in stream_data_waiting()
2025 let (tx1, rx1) = channel(); in shared_data_waiting()
2029 rx1.recv().unwrap(); in shared_data_waiting()
2032 _n = rx1.recv() => {} in shared_data_waiting()
2071 let (tx1, rx1) = sync_channel::<i32>(0); in sync3()
2080 n = rx1.recv() => { in sync3()
2088 assert_eq!(rx1.recv().unwrap(), 1); in sync3()