Struct FutureVector

pub(crate) struct FutureVector<R, E, F: Future<Output = Result<R, E>> + Unpin> {
    vec: Vec<F>,
}

Collect futures and await one or all of them.

Fields

vec: Vec<F>

Pending futures.

Implementations

impl<R, E, F: Future<Output = Result<R, E>> + Unpin> FutureVector<R, E, F>

pub fn new() -> Self

Create a new FutureVector.

pub fn push(&mut self, future: F)

Add a future.

pub fn is_empty(&self) -> bool

true if and only if there are no pending futures.

pub fn len(&self) -> usize

Number of pending futures.

pub fn select(&mut self) -> FutureVectorSelect<'_, R, E, F>

Await any one future.

Return the result of the first future that becomes ready, removing it from the vector.

Functionally, behaves like:

async fn select(&mut self) -> Result<R, E>;

pub fn discarding_join(&mut self) -> FutureVectorDiscardingJoin<'_, R, E, F>

Join all futures, discarding successful results.

If an error occurs, return it immediately. All pending futures remain.

Functionally, behaves like:

async fn discarding_join(&mut self) -> Result<(), E>;