Lines Matching refs:tx1
22 let (tx1, rx1) = oneshot::channel::<i32>(); in join()
33 tx1.send(1).unwrap(); in join()
47 let (tx1, rx1) = oneshot::channel::<i32>(); in select()
49 tx1.send(1).unwrap(); in select()
70 let (tx1, rx1) = oneshot::channel::<i32>(); in select_biased()
72 tx1.send(1).unwrap(); in select_biased()
94 let (mut tx1, rx1) = mpsc::channel::<i32>(1); in select_streams()
107 tx1.send(2).await.unwrap(); in select_streams()
109 tx1_opt = Some(tx1); in select_streams()
142 let (tx1, rx1) = oneshot::channel::<i32>(); in select_can_move_uncompleted_futures()
144 tx1.send(1).unwrap(); in select_can_move_uncompleted_futures()