Struct futures_util::compat::TokioDefaultSpawner

pub struct TokioDefaultSpawner;

A spawner that delegates to tokio's DefaultExecutor, will panic if used in the context of a task that is not running on tokio's executor.

NOTE The future of this struct in futures is uncertain. It may be deprecated before or soon after the initial 0.3 release and moved to a feature in tokio instead.

Examples

#![feature(async_await, await_macro, futures_api)]
use futures::future::{FutureExt, TryFutureExt};
use futures::spawn;
use futures::compat::TokioDefaultSpawner;

let future03 = async {
    println!("Running on the pool");
    spawn!(async {
        println!("Spawned!");
    }).unwrap();
};

let future01 = future03
    .unit_error() // Make it a TryFuture
    .boxed()  // Make it Unpin
    .compat(TokioDefaultSpawner);

tokio::run(future01);

Trait Implementations

impl Debug for TokioDefaultSpawner

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

Formats the value using the given formatter.

impl Copy for TokioDefaultSpawner

impl Clone for TokioDefaultSpawner

fn clone(&self) -> TokioDefaultSpawner

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Spawn for TokioDefaultSpawner

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

🔬 This is a nightly-only experimental API. (futures_api)

futures in libcore are unstable

Spawns a new task with the given future. The future will be polled until completion.

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

🔬 This is a nightly-only experimental API. (futures_api)

futures in libcore are unstable

Determines whether the executor is able to spawn new tasks.