Struct FutureRaceCompletionPool 

pub struct FutureRaceCompletionPool { /* private fields */ }

Pool that runs handed-off futures to completion. Cheap to clone.

Implementations

impl FutureRaceCompletionPool

pub fn new(name: impl Into<String>) -> Self

Creates an empty pool; name labels spawned tasks for diagnostics.

pub fn spawn<F>(&self, future: F)

where F: Future<Output = ()> + Send + 'static,

Run future to completion in the background; result is dropped.

pub fn channel_spawn<F, T>(&self, future: F) -> Receiver<T>

where F: Future<Output = T> + Send + 'static, T: Send + 'static,

Run future to completion in the background and return a receiver that yields its result. Dropping the receiver does not cancel the future; the value is just discarded when it eventually arrives.

pub async fn shutdown(&self)

Wait for every in-flight future to complete. Acquiring the write lock implies all read guards have been released.

Trait Implementations

impl Clone for FutureRaceCompletionPool

fn clone(&self) -> FutureRaceCompletionPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FutureRaceCompletionPool

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

Formats the value using the given formatter.