Struct futures_util::compat::TokioDefaultSpawner

[+] Show declaration

pub struct TokioDefaultSpawner;

[−] Expand description

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

[+]

[+] Show hidden undocumented items

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

[+]

[+] Show hidden undocumented items

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

[−]

Formats the value using the given formatter.

impl Spawn for TokioDefaultSpawner

[+]

[+] Show hidden undocumented items

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.