Struct AsyncStreams 

pub struct AsyncStreams<'s, S>(pub &'s mut [S]);

A borrowed group of literal asynchronous object streams, without allocation.

Tuple Fields

0: &'s mut [S]

Trait Implementations

impl<'p, P: Digest<'p>, S: AsyncSource> AsyncObjects<'p, P> for AsyncStreams<'_, S>

type Error = <S as AsyncSource>::Error

Original acquisition or format-specific comparison failure.

fn len(&self) -> usize

Number of original objects, including repeated group occurrences.

async fn run<W: Work>( &mut self, index: usize, batch: DigestBatch<'p, P>, work: &W, ) -> PassResult<DigestMemo<'p, P>, Self::Error, P::Error>

Completes this batch for the original object at index. The supplied work applies to acquisition, validation and the batch’s own callbacks.

fn is_empty(&self) -> bool

Whether the supplied group has no objects.