Struct ProcessResults

pub struct ProcessResults<I, T, E>
where
    I: AsyncIterator<Item = Result<T, E>>,
{ /* private fields */ }

A future that processes results from an asynchronous iterator, collecting successes and errors based on the specified strategy.

Implementations

impl<I, T, E> ProcessResults<I, T, E>

where I: AsyncIterator<Item = Result<T, E>>,

pub fn new(iter: I) -> ProcessResults<I, T, E>

Constructs a new ProcessResults future using the given async iterator.

pub fn with_process_strategy(self, strategy: ProcessResultsStrategy) -> Self

Sets the processing strategy to use for handling errors during iteration.

Trait Implementations

impl<I, T, E> Debug for ProcessResults<I, T, E>

where I: AsyncIterator<Item = Result<T, E>> + Debug,

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

Formats the value using the given formatter.

impl<I, T, E> Future for ProcessResults<I, T, E>

where I: AsyncIterator<Item = Result<T, E>> + Unpin, T: Unpin, E: Unpin,

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Polls the future and returns a container of results. Depending on the strategy, it either:

• Partition: Collects all successes and errors.
• BreakOnError: Stops at the first error and returns it immediately.

type Output = ProcessResultsContainer<T, E>

The type of value produced on completion.