[−][src]Trait futures_util::task::SpawnExt
Extension trait for Spawn
.
Provided Methods
fn spawn<Fut>(&mut self, future: Fut) -> Result<(), SpawnError> where
Fut: Future<Output = ()> + Send + 'static,
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, futures_api)] 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::Output>, SpawnError> where
Fut: Future + Send + 'static,
Fut::Output: Send,
&mut self,
future: Fut
) -> Result<RemoteHandle<Fut::Output>, SpawnError> where
Fut: Future + Send + 'static,
Fut::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, futures_api)] 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);
fn compat(self) -> Compat<Self> where
Self: Sized,
Self: Sized,
Wraps a Spawn
and makes it usable as a futures 0.1 Executor
.
Requires the compat
feature to enable.
Implementors
impl<Sp: ?Sized> SpawnExt for Sp where
Sp: Spawn,
[src]
impl<Sp: ?Sized> SpawnExt for Sp where
Sp: Spawn,
fn spawn<Fut>(&mut self, future: Fut) -> Result<(), SpawnError> where
Fut: Future<Output = ()> + Send + 'static,
[src]
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::Output>, SpawnError> where
Fut: Future + Send + 'static,
Fut::Output: Send,
[src]
fn spawn_with_handle<Fut>(
&mut self,
future: Fut
) -> Result<RemoteHandle<Fut::Output>, SpawnError> where
Fut: Future + Send + 'static,
Fut::Output: Send,
ⓘImportant traits for Compat<W>fn compat(self) -> Compat<Self> where
Self: Sized,
[src]
fn compat(self) -> Compat<Self> where
Self: Sized,