| /wasmtime-44.0.1/crates/misc/component-async-tests/tests/scenario/ |
| H A D | streams.rs | 157 .run_concurrent(async |_| { in async_closed_streams()
190 .run_concurrent(async |_| { in async_closed_streams()
208 .run_concurrent(async move |accessor| { in async_closed_streams()
240 .run_concurrent(async move |accessor| { in async_closed_streams()
287 .run_concurrent(async move |accessor| { in async_closed_stream()
429 .run_concurrent(async |store| { in test_async_short_reads()
|
| H A D | round_trip_direct.rs | 65 .run_concurrent({ in test_round_trip_direct()
115 .run_concurrent(async |store| -> wasmtime::Result<_> { in test_round_trip_direct()
|
| H A D | round_trip.rs | 331 .run_concurrent(async move |accessor| { in test_round_trip_recurse()
384 .run_concurrent({ in test_round_trip()
464 store.run_concurrent(async |_| rx.await).await??; in test_round_trip()
524 .run_concurrent(async |store| { in test_round_trip()
|
| H A D | borrowing.rs | 110 .run_concurrent(async move |accessor| { in test_run_bool()
|
| H A D | post_return.rs | 80 .run_concurrent(async |accessor| { in test_yield_post_return()
|
| H A D | round_trip_many.rs | 248 .run_concurrent({ in test_round_trip_many()
389 .run_concurrent(async |store| -> wasmtime::Result<_> { in test_round_trip_many()
|
| H A D | transmit.rs | 367 .run_concurrent(async move |accessor| { in async_readiness()
487 .run_concurrent(async move |accessor| { in test_cancel()
752 .run_concurrent(async |accessor| { in test_transmit_with()
955 .run_concurrent(async move |accessor| { in test_synchronous_transmit()
|
| H A D | util.rs | 226 .run_concurrent(async |store| { in test_run_with_count()
|
| /wasmtime-44.0.1/tests/all/ |
| H A D | pulley.rs | 453 .run_concurrent(async move |accessor| { in pulley_provenance_test_async_components()
460 .run_concurrent(async move |accessor| { in pulley_provenance_test_async_components()
467 .run_concurrent(async move |accessor| { in pulley_provenance_test_async_components()
474 .run_concurrent(async move |accessor| { in pulley_provenance_test_async_components()
481 .run_concurrent(async move |accessor| { in pulley_provenance_test_async_components()
|
| H A D | component_model.rs | 79 .run_concurrent(async |access| func.call_concurrent(access, params).await) in call()
|
| /wasmtime-44.0.1/crates/wasi-tls/tests/p3/ |
| H A D | mod.rs | 59 .run_concurrent(async move |store| command.wasi_cli_run().call_run(store).await) in run_test()
|
| /wasmtime-44.0.1/tests/all/component_model/ |
| H A D | bindgen.rs | 125 .run_concurrent(async move |accessor| { in run()
288 .run_concurrent(async move |accessor| no_imports.call_bar(accessor).await) in run()
|
| H A D | async.rs | 842 .run_concurrent(async |_| wasmtime::error::Ok(())) in require_concurrency_support()
944 .run_concurrent(async |store| -> wasmtime::Result<()> { in cancel_host_task_does_not_leak()
|
| H A D | async_dynamic.rs | 269 .run_concurrent(async |store| { in stream_any_smoke()
|
| H A D | import.rs | 846 .run_concurrent(async move |accessor| { in test_stack_and_heap_args_and_rets()
970 .run_concurrent(async |store| { in test_stack_and_heap_args_and_rets()
|
| H A D | func.rs | 919 .run_concurrent(async move |accessor| { in async_reentrance()
1131 .run_concurrent(async move |accessor| { in task_return_trap()
1329 .run_concurrent(async |store| { in test_many_parameters()
1374 .run_concurrent(async move |accessor| { in test_many_parameters()
1762 .run_concurrent(async |store| { in test_many_results()
1852 .run_concurrent(async move |accessor| { in test_many_results()
|
| /wasmtime-44.0.1/crates/wasi/tests/all/p3/ |
| H A D | mod.rs | 39 .run_concurrent(async move |store| command.wasi_cli_run().call_run(store).await) in run_allow_blocking_current_thread()
|
| /wasmtime-44.0.1/crates/fuzzing/src/oracles/ |
| H A D | component_api.rs | 290 .run_concurrent(async |a| func.call_concurrent(a, params).await.unwrap()) in static_api_test()
387 .run_concurrent(async |a| { in dynamic_component_api_target()
|
| H A D | component_async.rs | 237 .run_concurrent(async |store| { in run()
|
| /wasmtime-44.0.1/crates/wasi-http/tests/all/p3/ |
| H A D | mod.rs | 145 .run_concurrent(async |store| command.wasi_cli_run().call_run(store).await) in run_cli()
174 .run_concurrent(async |store| { in run_http()
|
| /wasmtime-44.0.1/crates/wasi-http/src/ |
| H A D | handler.rs | 318 let mut future = pin!(store.run_concurrent(async |accessor| { in run_()
|
| /wasmtime-44.0.1/src/commands/ |
| H A D | run.rs | 847 .run_concurrent(async |store| func.call_concurrent(store, params, results).await) in call_component_func()
877 .run_concurrent(async |store| command.wasi_cli_run().call_run(store).await) in run_command_component()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/ |
| H A D | concurrent.rs | 896 pub async fn run_concurrent<R>(&mut self, fun: impl AsyncFnOnce(&Accessor<T>) -> R) -> Result<R> in run_concurrent() method
904 self.as_context_mut().run_concurrent(fun).await in run_concurrent()
1092 pub async fn run_concurrent<R>(self, fun: impl AsyncFnOnce(&Accessor<T>) -> R) -> Result<R> in run_concurrent() method
|