Lines Matching refs:rx
177 $($name:pat = $rx:ident.$meth:ident() => $code:expr),+
183 $meth(($rx).inner) -> res => {
209 let (tx, rx) = channel::<i32>(); in smoke()
211 assert_eq!(rx.recv().unwrap(), 1); in smoke()
230 let (tx, rx) = channel::<i32>(); in smoke_shared()
232 assert_eq!(rx.recv().unwrap(), 1); in smoke_shared()
235 assert_eq!(rx.recv().unwrap(), 1); in smoke_shared()
240 let (tx, rx) = channel::<i32>(); in smoke_threads()
244 assert_eq!(rx.recv().unwrap(), 1); in smoke_threads()
250 let (tx, rx) = channel::<i32>(); in smoke_port_gone()
251 drop(rx); in smoke_port_gone()
257 let (tx, rx) = channel::<i32>(); in smoke_shared_port_gone()
258 drop(rx); in smoke_shared_port_gone()
264 let (tx, rx) = channel::<i32>(); in smoke_shared_port_gone2()
265 drop(rx); in smoke_shared_port_gone2()
273 let (tx, rx) = channel::<i32>(); in port_gone_concurrent()
275 rx.recv().unwrap(); in port_gone_concurrent()
283 let (tx, rx) = channel::<i32>(); in port_gone_concurrent_shared()
286 rx.recv().unwrap(); in port_gone_concurrent_shared()
294 let (tx, rx) = channel::<i32>(); in smoke_chan_gone()
296 assert!(rx.recv().is_err()); in smoke_chan_gone()
301 let (tx, rx) = channel::<()>(); in smoke_chan_gone_shared()
305 assert!(rx.recv().is_err()); in smoke_chan_gone_shared()
310 let (tx, rx) = channel::<i32>(); in chan_gone_concurrent()
315 while rx.recv().is_ok() {} in chan_gone_concurrent()
326 let (tx, rx) = channel::<i32>(); in stress()
333 assert_eq!(rx.recv().unwrap(), 1); in stress()
342 let (tx, rx) = channel::<i32>(); in stress_shared()
346 assert_eq!(rx.recv().unwrap(), 1); in stress_shared()
348 assert!(rx.try_recv().is_err()); in stress_shared()
390 let (tx, rx) = channel::<i32>(); in recv_from_outside_runtime()
393 assert_eq!(rx.recv().unwrap(), 1); in recv_from_outside_runtime()
421 let (_tx, rx) = channel::<i32>(); in oneshot_single_thread_close_port_first()
422 drop(rx); in oneshot_single_thread_close_port_first()
435 let (tx, rx) = channel::<Box<i32>>(); in oneshot_single_thread_send_port_close()
436 drop(rx); in oneshot_single_thread_send_port_close()
442 let (tx, rx) = channel::<i32>(); in oneshot_single_thread_recv_chan_close()
444 assert_eq!(rx.recv(), Err(RecvError)); in oneshot_single_thread_recv_chan_close()
449 let (tx, rx) = channel::<Box<i32>>(); in oneshot_single_thread_send_then_recv()
451 assert!(*rx.recv().unwrap() == 10); in oneshot_single_thread_send_then_recv()
456 let (tx, rx) = channel::<i32>(); in oneshot_single_thread_try_send_open()
458 assert!(rx.recv().unwrap() == 10); in oneshot_single_thread_try_send_open()
463 let (tx, rx) = channel::<i32>(); in oneshot_single_thread_try_send_closed()
464 drop(rx); in oneshot_single_thread_try_send_closed()
470 let (tx, rx) = channel::<i32>(); in oneshot_single_thread_try_recv_open()
472 assert!(rx.recv() == Ok(10)); in oneshot_single_thread_try_recv_open()
477 let (tx, rx) = channel::<i32>(); in oneshot_single_thread_try_recv_closed()
479 assert!(rx.recv().is_err()); in oneshot_single_thread_try_recv_closed()
484 let (tx, rx) = channel::<i32>(); in oneshot_single_thread_peek_data()
485 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in oneshot_single_thread_peek_data()
487 assert_eq!(rx.try_recv(), Ok(10)); in oneshot_single_thread_peek_data()
492 let (tx, rx) = channel::<i32>(); in oneshot_single_thread_peek_close()
494 assert_eq!(rx.try_recv(), Err(TryRecvError::Disconnected)); in oneshot_single_thread_peek_close()
495 assert_eq!(rx.try_recv(), Err(TryRecvError::Disconnected)); in oneshot_single_thread_peek_close()
500 let (_tx, rx) = channel::<i32>(); in oneshot_single_thread_peek_open()
501 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in oneshot_single_thread_peek_open()
506 let (tx, rx) = channel::<Box<i32>>(); in oneshot_multi_task_recv_then_send()
508 assert!(*rx.recv().unwrap() == 10); in oneshot_multi_task_recv_then_send()
517 let (tx, rx) = channel::<Box<i32>>(); in oneshot_multi_task_recv_then_close()
522 assert_eq!(rx.recv(), Err(RecvError)); in oneshot_multi_task_recv_then_close()
534 let (tx, rx) = channel::<i32>(); in oneshot_multi_thread_close_stress()
536 drop(rx); in oneshot_multi_thread_close_stress()
551 let (tx, rx) = channel::<i32>(); in oneshot_multi_thread_send_close_stress()
553 drop(rx); in oneshot_multi_thread_send_close_stress()
572 let (tx, rx) = channel::<i32>(); in oneshot_multi_thread_recv_close_stress()
575 assert_eq!(rx.recv(), Err(RecvError)); in oneshot_multi_thread_recv_close_stress()
599 let (tx, rx) = channel::<Box<isize>>(); in oneshot_multi_thread_send_recv_stress()
604 assert!(*rx.recv().unwrap() == 10); in oneshot_multi_thread_send_recv_stress()
616 let (tx, rx) = channel(); in stream_send_recv_stress()
621 if let Some(t2) = recv(rx, 0) { in stream_send_recv_stress()
636 fn recv(rx: Receiver<Box<i32>>, i: i32) -> Option<JoinHandle<()>> { in stream_send_recv_stress()
642 assert!(*rx.recv().unwrap() == i); in stream_send_recv_stress()
643 recv(rx, i + 1); in stream_send_recv_stress()
654 let (tx, rx) = channel(); in oneshot_single_thread_recv_timeout()
656 assert_eq!(rx.recv_timeout(Duration::from_millis(1)), Ok(())); in oneshot_single_thread_recv_timeout()
658 rx.recv_timeout(Duration::from_millis(1)), in oneshot_single_thread_recv_timeout()
662 assert_eq!(rx.recv_timeout(Duration::from_millis(1)), Ok(())); in oneshot_single_thread_recv_timeout()
667 let (tx, rx) = channel(); in stress_recv_timeout_two_threads()
682 match rx.recv_timeout(timeout) { in stress_recv_timeout_two_threads()
698 let (tx, rx) = channel::<()>(); in recv_timeout_upgrade()
703 assert_eq!(rx.recv_timeout(timeout), Err(RecvTimeoutError::Timeout)); in recv_timeout_upgrade()
709 let (tx, rx) = channel(); in stress_recv_timeout_shared()
726 match rx.recv_timeout(Duration::from_millis(10)) { in stress_recv_timeout_shared()
750 let (tx, rx) = channel(); in recv_a_lot()
755 rx.recv().unwrap(); in recv_a_lot()
761 let (tx, rx) = channel(); in shared_recv_timeout()
773 rx.recv().unwrap(); in shared_recv_timeout()
777 rx.recv_timeout(Duration::from_millis(1)), in shared_recv_timeout()
781 assert_eq!(rx.recv_timeout(Duration::from_millis(1)), Ok(())); in shared_recv_timeout()
789 let (tx, rx) = channel(); in shared_chan_stress()
801 rx.recv().unwrap(); in shared_chan_stress()
810 let (tx, rx) = channel::<i32>(); in test_nested_recv_iter()
815 for x in rx.iter() { in test_nested_recv_iter()
831 let (tx, rx) = channel::<i32>(); in test_recv_iter_break()
836 for x in rx.iter() { in test_recv_iter_break()
886 let (tx, rx) = channel::<i32>(); in test_recv_into_iter_owned()
890 rx.into_iter() in test_recv_into_iter_owned()
899 let (tx, rx) = channel::<i32>(); in test_recv_into_iter_borrowed()
903 let mut iter = (&rx).into_iter(); in test_recv_into_iter_borrowed()
938 let (tx, rx) = channel(); in destroy_upgraded_shared_port_when_sender_still_active()
941 rx.recv().unwrap(); // wait on a oneshot in destroy_upgraded_shared_port_when_sender_still_active()
942 drop(rx); // destroy a shared in destroy_upgraded_shared_port_when_sender_still_active()
984 let (tx, rx) = sync_channel::<i32>(1); in smoke()
986 assert_eq!(rx.recv().unwrap(), 1); in smoke()
997 let (tx, rx) = sync_channel::<i32>(1); in smoke_shared()
999 assert_eq!(rx.recv().unwrap(), 1); in smoke_shared()
1002 assert_eq!(rx.recv().unwrap(), 1); in smoke_shared()
1007 let (tx, rx) = sync_channel::<i32>(1); in recv_timeout()
1009 rx.recv_timeout(Duration::from_millis(1)), in recv_timeout()
1013 assert_eq!(rx.recv_timeout(Duration::from_millis(1)), Ok(1)); in recv_timeout()
1018 let (tx, rx) = sync_channel::<i32>(0); in smoke_threads()
1022 assert_eq!(rx.recv().unwrap(), 1); in smoke_threads()
1028 let (tx, rx) = sync_channel::<i32>(0); in smoke_port_gone()
1029 drop(rx); in smoke_port_gone()
1035 let (tx, rx) = sync_channel::<i32>(0); in smoke_shared_port_gone2()
1036 drop(rx); in smoke_shared_port_gone2()
1044 let (tx, rx) = sync_channel::<i32>(0); in port_gone_concurrent()
1046 rx.recv().unwrap(); in port_gone_concurrent()
1054 let (tx, rx) = sync_channel::<i32>(0); in port_gone_concurrent_shared()
1057 rx.recv().unwrap(); in port_gone_concurrent_shared()
1065 let (tx, rx) = sync_channel::<i32>(0); in smoke_chan_gone()
1067 assert!(rx.recv().is_err()); in smoke_chan_gone()
1072 let (tx, rx) = sync_channel::<()>(0); in smoke_chan_gone_shared()
1076 assert!(rx.recv().is_err()); in smoke_chan_gone_shared()
1081 let (tx, rx) = sync_channel::<i32>(0); in chan_gone_concurrent()
1086 while rx.recv().is_ok() {} in chan_gone_concurrent()
1097 let (tx, rx) = sync_channel::<i32>(0); in stress()
1104 assert_eq!(rx.recv().unwrap(), 1); in stress()
1116 let (tx, rx) = sync_channel::<i32>(0); in stress_recv_timeout_two_threads()
1126 match rx.recv_timeout(Duration::from_millis(1)) { in stress_recv_timeout_two_threads()
1147 let (tx, rx) = sync_channel::<i32>(0); in stress_recv_timeout_shared()
1153 match rx.recv_timeout(Duration::from_millis(10)) { in stress_recv_timeout_shared()
1164 assert!(rx.try_recv().is_err()); in stress_recv_timeout_shared()
1196 let (tx, rx) = sync_channel::<i32>(0); in stress_shared()
1201 assert_eq!(rx.recv().unwrap(), 1); in stress_shared()
1203 assert!(rx.try_recv().is_err()); in stress_shared()
1228 let (_tx, rx) = sync_channel::<i32>(0); in oneshot_single_thread_close_port_first()
1229 drop(rx); in oneshot_single_thread_close_port_first()
1242 let (tx, rx) = sync_channel::<Box<i32>>(0); in oneshot_single_thread_send_port_close()
1243 drop(rx); in oneshot_single_thread_send_port_close()
1249 let (tx, rx) = sync_channel::<i32>(0); in oneshot_single_thread_recv_chan_close()
1251 assert_eq!(rx.recv(), Err(RecvError)); in oneshot_single_thread_recv_chan_close()
1256 let (tx, rx) = sync_channel::<Box<i32>>(1); in oneshot_single_thread_send_then_recv()
1258 assert!(*rx.recv().unwrap() == 10); in oneshot_single_thread_send_then_recv()
1263 let (tx, rx) = sync_channel::<i32>(1); in oneshot_single_thread_try_send_open()
1265 assert!(rx.recv().unwrap() == 10); in oneshot_single_thread_try_send_open()
1270 let (tx, rx) = sync_channel::<i32>(0); in oneshot_single_thread_try_send_closed()
1271 drop(rx); in oneshot_single_thread_try_send_closed()
1283 let (tx, rx) = sync_channel::<i32>(1); in oneshot_single_thread_try_recv_open()
1285 assert!(rx.recv() == Ok(10)); in oneshot_single_thread_try_recv_open()
1290 let (tx, rx) = sync_channel::<i32>(0); in oneshot_single_thread_try_recv_closed()
1292 assert!(rx.recv().is_err()); in oneshot_single_thread_try_recv_closed()
1297 let (tx, rx) = sync_channel::<i32>(1); in oneshot_single_thread_try_recv_closed_with_data()
1300 assert_eq!(rx.try_recv(), Ok(10)); in oneshot_single_thread_try_recv_closed_with_data()
1301 assert_eq!(rx.try_recv(), Err(TryRecvError::Disconnected)); in oneshot_single_thread_try_recv_closed_with_data()
1306 let (tx, rx) = sync_channel::<i32>(1); in oneshot_single_thread_peek_data()
1307 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in oneshot_single_thread_peek_data()
1309 assert_eq!(rx.try_recv(), Ok(10)); in oneshot_single_thread_peek_data()
1314 let (tx, rx) = sync_channel::<i32>(0); in oneshot_single_thread_peek_close()
1316 assert_eq!(rx.try_recv(), Err(TryRecvError::Disconnected)); in oneshot_single_thread_peek_close()
1317 assert_eq!(rx.try_recv(), Err(TryRecvError::Disconnected)); in oneshot_single_thread_peek_close()
1322 let (_tx, rx) = sync_channel::<i32>(0); in oneshot_single_thread_peek_open()
1323 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in oneshot_single_thread_peek_open()
1328 let (tx, rx) = sync_channel::<Box<i32>>(0); in oneshot_multi_task_recv_then_send()
1330 assert!(*rx.recv().unwrap() == 10); in oneshot_multi_task_recv_then_send()
1339 let (tx, rx) = sync_channel::<Box<i32>>(0); in oneshot_multi_task_recv_then_close()
1344 assert_eq!(rx.recv(), Err(RecvError)); in oneshot_multi_task_recv_then_close()
1356 let (tx, rx) = sync_channel::<i32>(0); in oneshot_multi_thread_close_stress()
1358 drop(rx); in oneshot_multi_thread_close_stress()
1373 let (tx, rx) = sync_channel::<i32>(0); in oneshot_multi_thread_send_close_stress()
1375 drop(rx); in oneshot_multi_thread_send_close_stress()
1394 let (tx, rx) = sync_channel::<i32>(0); in oneshot_multi_thread_recv_close_stress()
1397 assert_eq!(rx.recv(), Err(RecvError)); in oneshot_multi_thread_recv_close_stress()
1420 let (tx, rx) = sync_channel::<Box<i32>>(0); in oneshot_multi_thread_send_recv_stress()
1425 assert!(*rx.recv().unwrap() == 10); in oneshot_multi_thread_send_recv_stress()
1437 let (tx, rx) = sync_channel::<Box<i32>>(0); in stream_send_recv_stress()
1442 if let Some(t) = recv(rx, 0) { in stream_send_recv_stress()
1457 fn recv(rx: Receiver<Box<i32>>, i: i32) -> Option<JoinHandle<()>> { in stream_send_recv_stress()
1463 assert!(*rx.recv().unwrap() == i); in stream_send_recv_stress()
1464 recv(rx, i + 1); in stream_send_recv_stress()
1481 let (tx, rx) = sync_channel(N); in recv_a_lot()
1486 rx.recv().unwrap(); in recv_a_lot()
1492 let (tx, rx) = sync_channel(0); in shared_chan_stress()
1504 rx.recv().unwrap(); in shared_chan_stress()
1513 let (tx, rx) = sync_channel::<i32>(0); in test_nested_recv_iter()
1518 for x in rx.iter() { in test_nested_recv_iter()
1534 let (tx, rx) = sync_channel::<i32>(0); in test_recv_iter_break()
1539 for x in rx.iter() { in test_recv_iter_break()
1587 let (tx, rx) = sync_channel::<()>(0); in destroy_upgraded_shared_port_when_sender_still_active()
1590 rx.recv().unwrap(); // wait on a oneshot in destroy_upgraded_shared_port_when_sender_still_active()
1591 drop(rx); // destroy a shared in destroy_upgraded_shared_port_when_sender_still_active()
1611 let (tx, rx) = sync_channel::<i32>(0); in send1()
1613 rx.recv().unwrap(); in send1()
1621 let (tx, rx) = sync_channel::<i32>(0); in send2()
1623 drop(rx); in send2()
1631 let (tx, rx) = sync_channel::<i32>(1); in send3()
1634 drop(rx); in send3()
1642 let (tx, rx) = sync_channel::<i32>(0); in send4()
1654 drop(rx); in send4()
1676 let (tx, rx) = sync_channel::<i32>(1); in try_send3()
1678 drop(rx); in try_send3()
1925 let (tx, rx) = channel(); in preflight1()
1928 _n = rx.recv() => {} in preflight1()
1934 let (tx, rx) = channel(); in preflight2()
1938 _n = rx.recv() => {} in preflight2()
1944 let (tx, rx) = channel(); in preflight3()
1948 _n = rx.recv() => {} in preflight3()
1954 let (tx, rx) = channel(); in preflight4()
1957 _ = rx.recv() => {} in preflight4()
1963 let (tx, rx) = channel(); in preflight5()
1967 _ = rx.recv() => {} in preflight5()
1973 let (tx, rx) = channel(); in preflight6()
1977 _ = rx.recv() => {} in preflight6()
1983 let (tx, rx) = channel::<()>(); in preflight7()
1986 _ = rx.recv() => {} in preflight7()
1992 let (tx, rx) = channel(); in preflight8()
1995 rx.recv().unwrap(); in preflight8()
1997 _ = rx.recv() => {} in preflight8()
2003 let (tx, rx) = channel(); in preflight9()
2007 rx.recv().unwrap(); in preflight9()
2009 _ = rx.recv() => {} in preflight9()
2079 let (tx, rx) = sync_channel::<i32>(1); in sync1()
2082 n = rx.recv() => { assert_eq!(n.unwrap(), 1); } in sync1()
2088 let (tx, rx) = sync_channel::<i32>(0); in sync2()
2096 n = rx.recv() => { assert_eq!(n.unwrap(), 1); } in sync2()