Lines Matching refs:rx1
22 let (tx1, rx1) = oneshot::channel::<i32>(); in join()
26 let res = join!(rx1, rx2); in join()
47 let (tx1, rx1) = oneshot::channel::<i32>(); in select()
53 res = rx1.fuse() => { in select()
70 let (tx1, rx1) = oneshot::channel::<i32>(); in select_biased()
76 res = rx1.fuse() => { in select_biased()
94 let (mut tx1, rx1) = mpsc::channel::<i32>(1); in select_streams()
96 let mut rx1 = rx1.fuse(); in select_streams() localVariable
104 _ = rx1.next() => panic!(), in select_streams()
117 x = rx1.next() => if let Some(x) = x { total += x; }, in select_streams()
142 let (tx1, rx1) = oneshot::channel::<i32>(); in select_can_move_uncompleted_futures()
147 let mut rx1 = rx1.fuse(); in select_can_move_uncompleted_futures() localVariable
151 res = rx1 => { in select_can_move_uncompleted_futures()
158 assert_eq!(Ok(1), rx1.await); in select_can_move_uncompleted_futures()