Trait futures::task::SpawnExt

[+] Show declaration

pub trait SpawnExt: Spawn {
    fn spawn<Fut>(&mut self, future: Fut) -> Result<(), SpawnError>
    where
        Fut: Future<Output = ()> + Send + 'static,
    { ... }
    fn spawn_with_handle<Fut>(
        &mut self, 
        future: Fut
    ) -> Result<RemoteHandle<<Fut as Future>::Output>, SpawnError>
    where
        Fut: Future + Send + 'static,
        <Fut as Future>::Output: Send,
    { ... }
    fn compat(self) -> Compat<Self> { ... }
}

[−] Expand description

Extension trait for Spawn.

Provided methods

fn spawn<Fut>(&mut self, future: Fut) -> Result<(), SpawnError> where
    Fut: Future<Output = ()> + Send + 'static, [+]

Spawns a task that polls the given future with output () to completion.

This method returns a Result that contains a SpawnError if spawning fails.

You can use spawn_with_handle if you want to spawn a future with output other than () or if you want to be able to await its completion.

Note this method will eventually be replaced with the upcoming Spawn::spawn method which will take a dyn Future as input. Technical limitations prevent Spawn::spawn from being implemented today. Feel free to use this method in the meantime.

#![feature(async_await, await_macro)]
use futures::executor::ThreadPool;
use futures::task::SpawnExt;

let mut executor = ThreadPool::new().unwrap();

let future = async { /* ... */ };
executor.spawn(future).unwrap();

fn spawn_with_handle<Fut>(
    &mut self,
    future: Fut
) -> Result<RemoteHandle<<Fut as Future>::Output>, SpawnError> where
    Fut: Future + Send + 'static,
    <Fut as Future>::Output: Send, [+]

Spawns a task that polls the given future to completion and returns a future that resolves to the spawned future's output.

This method returns a Result that contains a [RemoteHandle], or, if spawning fails, a SpawnError. [RemoteHandle] is a future that resolves to the output of the spawned future.

#![feature(async_await, await_macro)]
use futures::executor::ThreadPool;
use futures::future;
use futures::task::SpawnExt;

let mut executor = ThreadPool::new().unwrap();

let future = future::ready(1);
let join_handle_fut = executor.spawn_with_handle(future).unwrap();
assert_eq!(executor.run(join_handle_fut), 1);

Important traits for Compat<W>

impl<W> Write for Compat<W> where
    W: Unpin + AsyncWrite, impl<R> Read for Compat<R> where
    R: Unpin + AsyncRead, 

fn compat(self) -> Compat<Self>[+]

Wraps a Spawn and makes it usable as a futures 0.1 Executor. Requires the compat feature to enable.

Implementors

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

fn spawn<Fut>(&mut self, future: Fut) -> Result<(), SpawnError> where
    Fut: Future<Output = ()> + Send + 'static, 

fn spawn_with_handle<Fut>(
    &mut self,
    future: Fut
) -> Result<RemoteHandle<<Fut as Future>::Output>, SpawnError> where
    Fut: Future + Send + 'static,
    <Fut as Future>::Output: Send, 

Important traits for Compat<W>

impl<W> Write for Compat<W> where
    W: Unpin + AsyncWrite, impl<R> Read for Compat<R> where
    R: Unpin + AsyncRead, 

fn compat(self) -> Compat<Self>