Struct Join 

pub struct Join<T> { /* private fields */ }

Concurrently waits for the results of multiple tasks.

Implementations

impl<T> Join<T>

where T: Send + 'static,

pub fn new() -> Self

Creates an empty join.

pub fn add(&mut self, task: impl Start<T>) -> Index

Adds a task to the join, returning its index.

pub fn add_as( &mut self, name: impl Into<SharedString>, task: impl Start<T>, ) -> Index

Adds a named task to the join, returning its index.

pub async fn next(&mut self) -> Option<StoppedTask<Result<T, Panic>>>

Waits for the next stopped task.

If all tasks have stopped, this function returns None.

pub async fn try_next(&mut self) -> Option<Result<StoppedTask<T>, PanickedTask>>

Waits for the next stopped task and returns its information as a Result.

If all tasks have stopped, this function returns None.

pub async fn drain(&mut self)

Waits for all tasks to stop, dropping their results.

pub async fn try_drain(&mut self) -> Result<(), PanickedTask>

Waits for all tasks to stop, dropping their results, until a task panics.

Trait Implementations

impl<T> Default for Join<T>

where T: Send + 'static,

fn default() -> Self

Returns the “default value” for a type.