Lines Matching refs:tx1
25 let (mut tx1, mut rx) = mpsc::channel(1); in multiple_senders_disconnect()
26 let (tx2, mut tx3, mut tx4) = (tx1.clone(), tx1.clone(), tx1.clone()); in multiple_senders_disconnect()
30 tx1.disconnect(); in multiple_senders_disconnect()
34 assert!(tx1.is_closed()); in multiple_senders_disconnect()
47 let (mut tx1, mut rx) = mpsc::unbounded(); in multiple_senders_disconnect()
48 let (tx2, mut tx3, mut tx4) = (tx1.clone(), tx1.clone(), tx1.clone()); in multiple_senders_disconnect()
52 tx1.disconnect(); in multiple_senders_disconnect()
56 assert!(tx1.is_closed()); in multiple_senders_disconnect()
72 let (mut tx1, mut rx) = mpsc::channel(1); in multiple_senders_close_channel()
73 let mut tx2 = tx1.clone(); in multiple_senders_close_channel()
76 tx1.close_channel(); in multiple_senders_close_channel()
78 assert!(tx1.is_closed()); in multiple_senders_close_channel()
88 let (tx1, mut rx) = mpsc::unbounded(); in multiple_senders_close_channel()
89 let mut tx2 = tx1.clone(); in multiple_senders_close_channel()
92 tx1.close_channel(); in multiple_senders_close_channel()
94 assert!(tx1.is_closed()); in multiple_senders_close_channel()