Trait futures::task::Spawn

[+] Show declaration

pub trait Spawn {
    fn spawn_obj(
        &mut self, 
        future: FutureObj<'static, ()>
    ) -> Result<(), SpawnError>;

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

[−] Expand description

The Spawn trait allows for pushing futures onto an executor that will run them to completion.

Required methods

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

Spawns a future that will be run to completion.

Errors

The executor may be unable to spawn tasks. Spawn errors should represent relatively rare scenarios, such as the executor having been shut down so that it is no longer able to accept tasks.

Provided methods

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

Determines whether the executor is able to spawn new tasks.

This method will return Ok when the executor is likely (but not guaranteed) to accept a subsequent spawn attempt. Likewise, an Err return means that spawn is likely, but not guaranteed, to yield an error.

Implementations on Foreign Types

impl<'_, Sp> Spawn for &'_ mut Sp where
    Sp: Spawn + ?Sized, [−]

[+] Show hidden undocumented items

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

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

impl<Sp> Spawn for Box<Sp> where
    Sp: Spawn + ?Sized, [−]

[+] Show hidden undocumented items

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

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

Implementors

impl Spawn for LocalSpawner[−]

[+] Show hidden undocumented items

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

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

impl Spawn for ThreadPool[−]

[+] Show hidden undocumented items

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

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

impl<'_> Spawn for &'_ ThreadPool[−]

[+] Show hidden undocumented items

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

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

impl<'_> Spawn for FuturesUnordered<FutureObj<'_, ()>>[−]

[+] Show hidden undocumented items

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

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

impl<Ex> Spawn for Executor01As03<Ex> where
    Ex: Executor<Compat<UnitError<FutureObj<'static, ()>>>> + Clone + Send + 'static, [−]

[+] Show hidden undocumented items

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

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

impl Spawn for LocalSpawner

impl Spawn for ThreadPool

impl<'_> Spawn for &'_ ThreadPool

impl Spawn for NoopSpawner

impl Spawn for PanicSpawner

impl Spawn for RecordSpawner

impl<'_> Spawn for FuturesUnordered<FutureObj<'_, ()>>

impl<Ex> Spawn for Executor01As03<Ex> where     Ex: Executor01<Executor01Future>,     Ex: Clone + Send + 'static,