Lines Matching refs:tx2
262 let tx2 = tx.clone(); in smoke_shared_port_gone2() localVariable
264 assert!(tx2.send(1).is_err()); in smoke_shared_port_gone2()
280 let tx2 = tx.clone(); in port_gone_concurrent_shared() localVariable
284 while tx.send(1).is_ok() && tx2.send(1).is_ok() {} in port_gone_concurrent_shared()
298 let tx2 = tx.clone(); in smoke_chan_gone_shared() localVariable
300 drop(tx2); in smoke_chan_gone_shared()
365 let (tx2, rx2) = channel::<i32>(); in send_from_outside_runtime()
375 tx2.send(1).unwrap(); in send_from_outside_runtime()
399 let (tx2, rx2) = channel::<i32>(); in no_runtime()
402 tx2.send(2).unwrap(); in no_runtime()
901 let (tx2, rx2) = channel::<()>(); in try_recv_states()
913 tx2.send(()).unwrap(); in try_recv_states()
917 tx2.send(()).unwrap(); in try_recv_states()
928 let (tx2, rx2) = channel(); in destroy_upgraded_shared_port_when_sender_still_active()
932 tx2.send(()).unwrap(); in destroy_upgraded_shared_port_when_sender_still_active()
940 let tx2 = tx.clone(); in destroy_upgraded_shared_port_when_sender_still_active() localVariable
942 tx2.send(()).unwrap(); in destroy_upgraded_shared_port_when_sender_still_active()
1027 let tx2 = tx.clone(); in smoke_shared_port_gone2() localVariable
1029 assert!(tx2.send(1).is_err()); in smoke_shared_port_gone2()
1045 let tx2 = tx.clone(); in port_gone_concurrent_shared() localVariable
1049 while tx.send(1).is_ok() && tx2.send(1).is_ok() {} in port_gone_concurrent_shared()
1063 let tx2 = tx.clone(); in smoke_chan_gone_shared() localVariable
1065 drop(tx2); in smoke_chan_gone_shared()
1533 let (tx2, rx2) = sync_channel::<()>(1); in try_recv_states()
1545 tx2.send(()).unwrap(); in try_recv_states()
1549 tx2.send(()).unwrap(); in try_recv_states()
1560 let (tx2, rx2) = sync_channel::<()>(0); in destroy_upgraded_shared_port_when_sender_still_active()
1564 tx2.send(()).unwrap(); in destroy_upgraded_shared_port_when_sender_still_active()
1572 let tx2 = tx.clone(); in destroy_upgraded_shared_port_when_sender_still_active() localVariable
1574 tx2.send(()).unwrap(); in destroy_upgraded_shared_port_when_sender_still_active()
1615 let tx2 = tx.clone(); in send4() localVariable
1623 assert!(tx2.send(2).is_err()); in send4()
1658 let (tx2, rx2) = sync_channel::<()>(3); in issue_15761()
1662 tx2.try_send(()).unwrap(); in issue_15761()
1684 let (tx2, rx2) = channel::<i32>(); in smoke()
1690 tx2.send(2).unwrap(); in smoke()
1700 drop(tx2); in smoke()
1726 let (tx2, rx2) = channel::<i32>(); in closed()
1727 drop(tx2); in closed()
1767 let (tx2, rx2) = channel::<i32>(); in both_ready()
1775 tx2.send(2).unwrap(); in both_ready()
1797 let (tx2, rx2) = channel::<i32>(); in stress()
1805 tx2.send(i).unwrap(); in stress()
1872 let (tx2, rx2) = channel::<()>(); in cloning3()
1886 tx2.send(()).unwrap(); in cloning3()
1984 let (tx2, rx2) = channel(); in oneshot_data_waiting()
1989 tx2.send(()).unwrap(); in oneshot_data_waiting()
2003 let (tx2, rx2) = channel(); in stream_data_waiting()
2012 tx2.send(()).unwrap(); in stream_data_waiting()
2026 let (tx2, rx2) = channel(); in shared_data_waiting()
2034 tx2.send(()).unwrap(); in shared_data_waiting()
2072 let (tx2, rx2): (Sender<i32>, Receiver<i32>) = channel(); in sync3()
2077 tx2.send(2).unwrap(); in sync3()