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 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 Copy for TokioDefaultSpawner

impl Debug for TokioDefaultSpawner

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

Formats the value using the given formatter.

impl Spawn for TokioDefaultSpawner

fn spawn_obj(     &mut 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.