Lines Matching refs:rx
21 let (tx, rx) = oneshot::channel::<i32>(); in send_shared_oneshot_and_wait_on_multiple_threads()
22 let f = rx.shared(); in send_shared_oneshot_and_wait_on_multiple_threads()
57 let (tx, rx) = oneshot::channel::<u32>(); in drop_on_one_task_ok()
58 let f1 = rx.shared(); in drop_on_one_task_ok()
132 let (tx, rx) = oneshot::channel::<i32>(); in downgrade()
133 let shared = rx.shared(); in downgrade()
160 let (tx, rx) = oneshot::channel::<i32>(); in ptr_eq()
161 let shared = rx.shared(); in ptr_eq()
192 let (_tx, rx) = oneshot::channel::<i32>(); in ptr_eq()
193 let shared4 = rx.shared(); in ptr_eq()
203 let (tx, rx) = oneshot::channel(); in dont_clone_in_single_owner_shared_future()
205 let rx = rx.shared(); in dont_clone_in_single_owner_shared_future() localVariable
209 assert_eq!(block_on(rx).unwrap().0.get(), 0); in dont_clone_in_single_owner_shared_future()
215 let (tx, rx) = oneshot::channel(); in dont_do_unnecessary_clones_on_output()
217 let rx = rx.shared(); in dont_do_unnecessary_clones_on_output() localVariable
221 assert_eq!(block_on(rx.clone()).unwrap().0.get(), 1); in dont_do_unnecessary_clones_on_output()
222 assert_eq!(block_on(rx.clone()).unwrap().0.get(), 2); in dont_do_unnecessary_clones_on_output()
223 assert_eq!(block_on(rx).unwrap().0.get(), 2); in dont_do_unnecessary_clones_on_output()