Lines Matching full:async
25 async fn local_current_thread_scheduler() { in local_current_thread_scheduler()
27 .run_until(async { in local_current_thread_scheduler()
28 task::spawn_local(async {}).await.unwrap(); in local_current_thread_scheduler()
35 async fn local_threadpool() { in local_threadpool()
43 .run_until(async { in local_threadpool()
45 task::spawn_local(async { in local_threadpool()
56 async fn localset_future_threadpool() { in localset_future_threadpool()
64 local.spawn_local(async move { in localset_future_threadpool()
72 async fn localset_future_timers() { in localset_future_timers()
77 local.spawn_local(async move { in localset_future_timers()
81 local.spawn_local(async move { in localset_future_timers()
91 async fn localset_future_drives_all_local_futs() { in localset_future_drives_all_local_futs()
97 local.spawn_local(async move { in localset_future_drives_all_local_futs()
98 task::spawn_local(async { in localset_future_drives_all_local_futs()
105 local.spawn_local(async move { in localset_future_drives_all_local_futs()
117 async fn local_threadpool_timer() { in local_threadpool_timer()
127 .run_until(async { in local_threadpool_timer()
129 let join = task::spawn_local(async move { in local_threadpool_timer()
144 let join = task::spawn_local(async { true }); in enter_guard_spawn()
149 local.block_on(&rt, async move { in enter_guard_spawn()
170 LocalSet::new().block_on(&rt, async { in local_threadpool_blocking_in_place()
172 let join = task::spawn_local(async move { in local_threadpool_blocking_in_place()
183 async fn local_threadpool_blocking_run() { in local_threadpool_blocking_run()
191 .run_until(async { in local_threadpool_blocking_run()
193 let join = task::spawn_local(async move { in local_threadpool_blocking_run()
212 async fn all_spawns_are_local() { in all_spawns_are_local()
221 .run_until(async { in all_spawns_are_local()
225 task::spawn_local(async { in all_spawns_are_local()
239 async fn nested_spawn_is_local() { in nested_spawn_is_local()
247 .run_until(async { in nested_spawn_is_local()
249 task::spawn_local(async { in nested_spawn_is_local()
251 task::spawn_local(async { in nested_spawn_is_local()
253 task::spawn_local(async { in nested_spawn_is_local()
255 task::spawn_local(async { in nested_spawn_is_local()
284 local.block_on(&rt, async move { in join_local_future_elsewhere()
286 let join = task::spawn_local(async move { in join_local_future_elsewhere()
295 let join2 = task::spawn(async move { in join_local_future_elsewhere()
312 async fn localset_in_thread_local() { in localset_in_thread_local()
323 handle.block_on(local_set.run_until(async move { in localset_in_thread_local()
342 local.spawn_local(async move { in drop_cancels_tasks()
350 local.block_on(&rt, async { in drop_cancels_tasks()
411 local.spawn_local(async move { while rx.recv().await.is_some() {} }); in drop_cancels_remote_tasks()
412 local.block_on(&rt, async { in drop_cancels_remote_tasks()
440 handles.push(set.spawn_local(async move { in local_tasks_wake_join_all()
441 tokio::task::spawn_local(async move {}).await.unwrap(); in local_tasks_wake_join_all()
468 async fn local_tasks_are_polled_after_tick_inner() { in local_tasks_are_polled_after_tick_inner()
483 .run_until(async { in local_tasks_are_polled_after_tick_inner()
484 let task2 = task::spawn(async move { in local_tasks_are_polled_after_tick_inner()
517 task::spawn_local(async move { in local_tasks_are_polled_after_tick_inner()
529 async fn acquire_mutex_in_drop() { in acquire_mutex_in_drop()
536 local.spawn_local(async move { in acquire_mutex_in_drop()
541 local.spawn_local(async move { in acquire_mutex_in_drop()
548 local.spawn_local(async move { in acquire_mutex_in_drop()
555 .run_until(async { in acquire_mutex_in_drop()
565 async fn spawn_wakes_localset() { in spawn_wakes_localset()
569 ret = async { local.spawn_local(ready(())).await.unwrap()}.fuse() => ret in spawn_wakes_localset()
597 async fn inner_method(&self) { in store_local_set_in_thread_local_with_runtime()
599 .run_until(async move { in store_local_set_in_thread_local_with_runtime()
600 tokio::task::spawn_local(async {}); in store_local_set_in_thread_local_with_runtime()
624 async fn shutdown_on_panic() { in shutdown_on_panic()
627 .run_until(async { in shutdown_on_panic()
628 tokio::task::spawn_local(async { in shutdown_on_panic()
644 async fn run_until_does_not_get_own_budget() { in run_until_does_not_get_own_budget()
649 .run_until(async { in run_until_does_not_get_own_budget()
650 let spawned = tokio::spawn(async { in run_until_does_not_get_own_budget()
654 let mut spawned = tokio_test::task::spawn(async { in run_until_does_not_get_own_budget()
669 let mut run_until = tokio_test::task::spawn(async { in run_until_does_not_get_own_budget()