Struct async_executors::exec::AsyncGlobal

pub struct AsyncGlobal;

Available on crate feature async_global only.

An executor that spawns tasks on async-global-executor. In contrast to the other executors, this one is not self contained, because async-global-executor does not provide an API that allows that, so the threadpool is global.

It works on Wasm.

Implementations

impl AsyncGlobal

pub fn new() -> Self

Create a new AsyncGlobal wrapper, forwards to Default::default.

pub fn block_on<F: Future>(future: F) -> F::Output

Available on non-target_os="unknown" only.

Wrapper around async_global_executor::block_on. This is not available on Wasm as Wasm does not have threads and you’re not allowed to block the only thread you have.

Trait Implementations

impl Clone for AsyncGlobal

fn clone(&self) -> AsyncGlobal

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AsyncGlobal

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for AsyncGlobal

fn default() -> AsyncGlobal

Returns the “default value” for a type.

impl LocalSpawn for AsyncGlobal

fn spawn_local_obj(
    &self,
    future: LocalFutureObj<'static, ()>
) -> Result<(), SpawnError>

Spawns a future that will be run to completion.

fn status_local(&self) -> Result<(), SpawnError>

Determines whether the executor is able to spawn new tasks.

impl<Out: 'static> LocalSpawnHandle<Out> for AsyncGlobal

fn spawn_handle_local_obj(
    &self,
    future: LocalFutureObj<'static, Out>
) -> Result<JoinHandle<Out>, SpawnError>

Spawn a future and return a JoinHandle that can be awaited for the output of the future.

impl Spawn for AsyncGlobal

fn spawn_obj(&self, future: FutureObj<'static, ()>) -> Result<(), SpawnError>

Spawns a future that will be run to completion.

fn status(&self) -> Result<(), SpawnError>

Determines whether the executor is able to spawn new tasks.

impl<R: Send + 'static> SpawnBlocking<R> for AsyncGlobal

fn spawn_blocking<F>(&self, f: F) -> BlockingHandle<R> where
    F: FnOnce() -> R + Send + 'static, 

Runs the provided closure on a thread where blocking is acceptable.

fn spawn_blocking_dyn(
    &self,
    f: Box<dyn FnOnce() -> R + Send>
) -> BlockingHandle<R>

Runs the provided closure on a thread where blocking is acceptable. This part of the trait is object safe but your closure must be boxed and you cannot have a return value.

impl<Out: 'static + Send> SpawnHandle<Out> for AsyncGlobal

fn spawn_handle_obj(
    &self,
    future: FutureObj<'static, Out>
) -> Result<JoinHandle<Out>, SpawnError>

Spawn a future and return a JoinHandle that can be awaited for the output of the future.

impl Timer for AsyncGlobal

Available on crate feature timer only.

fn sleep(&self, dur: Duration) -> BoxFuture<'static, ()>

Future that resolves after a given duration.

impl YieldNow for AsyncGlobal

fn yield_now(&self) -> YieldNowFut

Await this future in order to yield to the executor.

impl Copy for AsyncGlobal

impl TokioIo for AsyncGlobal

Available on non-WebAssembly and crate feature async_global_tokio only.

Signal io can be used on this executor.