Struct af_core::task::join::Join

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

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.