Searched refs:PollOnce (Results 1 – 5 of 5) sorted by relevance
277 let future = PollOnce::new(future).await; in cancel_during_run()449 match PollOnce::new(a).await { in async_mpk_protection()460 match PollOnce::new(b).await { in async_mpk_protection()485 let once = PollOnce::new(future); in execute_across_threads()810 pub struct PollOnce<F>(Option<F>); struct812 impl<F> PollOnce<F> { implementation813 pub fn new(future: F) -> PollOnce<F> { in new()814 PollOnce(Some(future)) in new()818 impl<F> Future for PollOnce<F> implementation909 let future = PollOnce::new(Box::pin({ in non_stacky_async_activations()
3 use crate::async_functions::{CountPending, PollOnce};494 let _ = PollOnce::new(Box::pin(f.call_async(&mut store, &[], &mut []))).await; in drop_future_on_epoch_yield()
916 use super::async_functions::PollOnce; in total_stacks_limit()962 let future1 = PollOnce::new(Box::pin(run1.call_async(store1, &[], &mut []))) in total_stacks_limit()969 let future2 = PollOnce::new(Box::pin(run2.call_async(store2, &[], &mut []))) in total_stacks_limit()
11 use crate::async_functions::PollOnce;1129 let poll_once = PollOnce::new(future); in invalidated_frame_handles_in_dropped_future()
1 use crate::async_functions::{PollOnce, execute_across_threads};224 match PollOnce::new(invoke_component).await { in poll_through_wasm_activation()