Lines Matching refs:tx1
24 let (mut tx1, mut rx) = mpsc::channel(1); in multiple_senders_disconnect()
25 let (tx2, mut tx3, mut tx4) = (tx1.clone(), tx1.clone(), tx1.clone()); in multiple_senders_disconnect()
29 tx1.disconnect(); in multiple_senders_disconnect()
33 assert!(tx1.is_closed()); in multiple_senders_disconnect()
46 let (mut tx1, mut rx) = mpsc::unbounded(); in multiple_senders_disconnect()
47 let (tx2, mut tx3, mut tx4) = (tx1.clone(), tx1.clone(), tx1.clone()); in multiple_senders_disconnect()
51 tx1.disconnect(); in multiple_senders_disconnect()
55 assert!(tx1.is_closed()); in multiple_senders_disconnect()
71 let (mut tx1, mut rx) = mpsc::channel(1); in multiple_senders_close_channel()
72 let mut tx2 = tx1.clone(); in multiple_senders_close_channel()
75 tx1.close_channel(); in multiple_senders_close_channel()
77 assert!(tx1.is_closed()); in multiple_senders_close_channel()
87 let (tx1, mut rx) = mpsc::unbounded(); in multiple_senders_close_channel()
88 let mut tx2 = tx1.clone(); in multiple_senders_close_channel()
91 tx1.close_channel(); in multiple_senders_close_channel()
93 assert!(tx1.is_closed()); in multiple_senders_close_channel()