Lines Matching refs:rx1
105 let (tx1, rx1) = oneshot::channel::<i32>(); in one_ready()
111 res = rx1 => { in one_ready()
122 let (tx1, mut rx1) = mpsc::unbounded_channel::<i32>(); in select_streams()
143 Some(x) = rx1.recv() => { in select_streams()
161 let (tx1, mut rx1) = oneshot::channel::<i32>(); in move_uncompleted_futures()
170 res = &mut rx1 => { in move_uncompleted_futures()
177 assert_eq!(1, assert_ok!(rx1.await)); in move_uncompleted_futures()
327 let (tx1, mut rx1) = oneshot::channel(); in join_with_select()
336 v1 = &mut rx1, if a.is_none() => a = Some(assert_ok!(v1)), in join_with_select()
487 let (_tx1, rx1) = oneshot::channel::<i32>(); in biased_one_not_ready()
497 _ = rx1 => unreachable!(), in biased_one_not_ready()