• Home
  • Raw
  • Download

Lines Matching refs:async

20 async fn local_basic_scheduler() {  in local_basic_scheduler()
22 .run_until(async { in local_basic_scheduler()
23 task::spawn_local(async {}).await.unwrap(); in local_basic_scheduler()
29 async fn local_threadpool() { in local_threadpool()
37 .run_until(async { in local_threadpool()
39 task::spawn_local(async { in local_threadpool()
49 async fn localset_future_threadpool() { in localset_future_threadpool()
57 local.spawn_local(async move { in localset_future_threadpool()
64 async fn localset_future_timers() { in localset_future_timers()
69 local.spawn_local(async move { in localset_future_timers()
73 local.spawn_local(async move { in localset_future_timers()
83 async fn localset_future_drives_all_local_futs() { in localset_future_drives_all_local_futs()
89 local.spawn_local(async move { in localset_future_drives_all_local_futs()
90 task::spawn_local(async { in localset_future_drives_all_local_futs()
97 local.spawn_local(async move { in localset_future_drives_all_local_futs()
108 async fn local_threadpool_timer() { in local_threadpool_timer()
118 .run_until(async { in local_threadpool_timer()
120 let join = task::spawn_local(async move { in local_threadpool_timer()
145 LocalSet::new().block_on(&rt, async { in local_threadpool_blocking_in_place()
147 let join = task::spawn_local(async move { in local_threadpool_blocking_in_place()
157 async fn local_threadpool_blocking_run() { in local_threadpool_blocking_run()
165 .run_until(async { in local_threadpool_blocking_run()
167 let join = task::spawn_local(async move { in local_threadpool_blocking_run()
185 async fn all_spawns_are_local() { in all_spawns_are_local()
194 .run_until(async { in all_spawns_are_local()
198 task::spawn_local(async { in all_spawns_are_local()
211 async fn nested_spawn_is_local() { in nested_spawn_is_local()
219 .run_until(async { in nested_spawn_is_local()
221 task::spawn_local(async { in nested_spawn_is_local()
223 task::spawn_local(async { in nested_spawn_is_local()
225 task::spawn_local(async { in nested_spawn_is_local()
227 task::spawn_local(async { in nested_spawn_is_local()
255 local.block_on(&rt, async move { in join_local_future_elsewhere()
257 let join = task::spawn_local(async move { in join_local_future_elsewhere()
268 let join2 = task::spawn(async move { in join_local_future_elsewhere()
297 local.spawn_local(async move { in drop_cancels_tasks()
305 local.block_on(&rt, async { in drop_cancels_tasks()
367 local.spawn_local(async move { while rx.recv().await.is_some() {} }); in drop_cancels_remote_tasks()
368 local.block_on(&rt, async { in drop_cancels_remote_tasks()
392 handles.push(set.spawn_local(async move { in local_tasks_wake_join_all()
393 tokio::task::spawn_local(async move {}).await.unwrap(); in local_tasks_wake_join_all()
418 async fn local_tasks_are_polled_after_tick_inner() { in local_tasks_are_polled_after_tick_inner()
433 .run_until(async { in local_tasks_are_polled_after_tick_inner()
434 let task2 = task::spawn(async move { in local_tasks_are_polled_after_tick_inner()
464 task::spawn_local(async move { in local_tasks_are_polled_after_tick_inner()
476 async fn acquire_mutex_in_drop() { in acquire_mutex_in_drop()
483 local.spawn_local(async move { in acquire_mutex_in_drop()
488 local.spawn_local(async move { in acquire_mutex_in_drop()
495 local.spawn_local(async move { in acquire_mutex_in_drop()
502 .run_until(async { in acquire_mutex_in_drop()
512 async fn spawn_wakes_localset() { in spawn_wakes_localset()
516 ret = async { local.spawn_local(ready(())).await.unwrap()}.fuse() => ret in spawn_wakes_localset()