Trait futures_concurrency::future::TryMerge

pub trait TryMerge {
    type Output;
    type Error;

    fn try_merge<'async_trait>(
        self
    ) -> Pin<Box<dyn Future<Output = Result<Self::Output, Self::Error>> + 'async_trait>>
    where
        Self: 'async_trait;
}

Wait for all futures to complete successfully, or abort early on error.

In the case a future errors, all other futures will be cancelled. If futures have been completed, their results will be discarded.

If you want to keep partial data in the case of failure, see the merge operation.

Required Associated Types

type Output

The resulting output type.

type Error

The resulting error type.

Required Methods

fn try_merge<'async_trait>(
    self
) -> Pin<Box<dyn Future<Output = Result<Self::Output, Self::Error>> + 'async_trait>>where
    Self: 'async_trait,

Waits for multiple futures to complete, either returning when all futures complete successfully, or return early when any future completes with an error.

Implementations on Foreign Types

impl<Fut, T, E, const N: usize> TryMerge for [Fut; N]where
    T: Debug,
    Fut: IntoFuture<Output = Result<T, E>>,
    E: Debug,

type Output = [T; N]

type Error = E

fn try_merge<'async_trait>(
    self
) -> Pin<Box<dyn Future<Output = Result<Self::Output, Self::Error>> + 'async_trait>>where
    Self: 'async_trait,

impl<Fut, T, E> TryMerge for Vec<Fut>where
    T: Debug,
    Fut: IntoFuture<Output = Result<T, E>>,

type Output = Vec<T, Global>

type Error = E

fn try_merge<'async_trait>(
    self
) -> Pin<Box<dyn Future<Output = Result<Self::Output, Self::Error>> + 'async_trait>>where
    Self: 'async_trait,

Implementors