Struct InspectChunksAsync 

pub struct InspectChunksAsync<F, Fut>
where
    F: FnMut(Chunk) -> Fut + Send + 'static,
    Fut: Future<Output = Next> + Send + 'static,
{
    pub f: F,
    pub _fut: PhantomData<fn() -> Fut>,
}

Asynchronous counterpart to InspectChunks. Construct via builder and pass to Consumable::consume_async.

Fields

f: F

Per-chunk async callback. The returned future yields Next::Break to stop early.

_fut: PhantomData<fn() -> Fut>

Phantom marker so the Fut bound lives on the struct (and on the derived builder) rather than only on the impl block. The closure’s return type carries Fut, so the builder infers it from f. Users never spell Fut out.

Implementations

impl<F, Fut> InspectChunksAsync<F, Fut>

where F: FnMut(Chunk) -> Fut + Send + 'static, Fut: Future<Output = Next> + Send + 'static,

pub fn builder() -> InspectChunksAsyncBuilder<F, Fut, ((),)>

Create a builder for building InspectChunksAsync. On the builder, call .f(...) to set the values of the fields. Finally, call .build() to create the instance of InspectChunksAsync.

Trait Implementations

impl<F, Fut> AsyncStreamVisitor for InspectChunksAsync<F, Fut>

where F: FnMut(Chunk) -> Fut + Send + 'static, Fut: Future<Output = Next> + Send + 'static,

type Output = ()

The value produced by into_output after the visitor has finished observing the stream. Returned via Consumer::wait and Consumer::cancel.

fn on_chunk(&mut self, chunk: Chunk) -> impl Future<Output = Next> + Send + '_

Asynchronously observes a single chunk.

fn into_output(self) -> Self::Output

Consumes the visitor and returns its final output.

fn on_gap(&mut self)

Invoked when the stream backend reports that one or more chunks were dropped between the last delivered chunk and the next one.

fn on_eof(&mut self) -> impl Future<Output = ()> + Send + '_

Asynchronously observes end-of-stream.