• Home
  • Raw
  • Download

Lines Matching refs:block_on

17     use futures::executor::block_on;  in send_shared_oneshot_and_wait_on_multiple_threads()
26 assert_eq!(block_on(cloned_future).unwrap(), 6); in send_shared_oneshot_and_wait_on_multiple_threads()
33 assert_eq!(block_on(f).unwrap(), 6); in send_shared_oneshot_and_wait_on_multiple_threads()
57 use futures::executor::block_on; in drop_on_one_task_ok()
69 drop(block_on(f)); in drop_on_one_task_ok()
75 let _ = block_on(f2.map_ok(|x| tx3.send(x).unwrap()).map_err(|_| ())); in drop_on_one_task_ok()
82 let result = block_on(rx3).unwrap(); in drop_on_one_task_ok()
89 use futures::executor::block_on; in drop_in_poll()
106 assert_eq!(block_on(future1), 1); in drop_in_poll()
149 use futures::executor::block_on; in downgrade()
160 assert_eq!(block_on(shared).unwrap(), 42); in downgrade()
167 assert_eq!(block_on(&mut shared2).unwrap(), 42); in downgrade()
177 use futures::executor::block_on; in dont_clone_in_single_owner_shared_future()
191 assert_eq!(block_on(rx).unwrap().0.get(), 0); in dont_clone_in_single_owner_shared_future()
197 use futures::executor::block_on; in dont_do_unnecessary_clones_on_output()
211 assert_eq!(block_on(rx.clone()).unwrap().0.get(), 1); in dont_do_unnecessary_clones_on_output()
212 assert_eq!(block_on(rx.clone()).unwrap().0.get(), 2); in dont_do_unnecessary_clones_on_output()
213 assert_eq!(block_on(rx).unwrap().0.get(), 2); in dont_do_unnecessary_clones_on_output()
218 use futures::executor::block_on; in shared_future_that_wakes_itself_until_pending_is_returned()
237 block_on(futures::future::join(fut, async { proceed.set(true) })), in shared_future_that_wakes_itself_until_pending_is_returned()