Struct InspectLineSinkAsync 

pub struct InspectLineSinkAsync<F, Fut> { /* private fields */ }

AsyncLineSink wrapping a per-line async closure. Compose with LineAdapter (its AsyncStreamVisitor impl is selected automatically when the inner sink is an AsyncLineSink) to drive inspect_lines_async. The PhantomData<fn() -> Fut> carries the future’s type onto the struct so callers never name Fut explicitly.

Implementations

impl<F, Fut> InspectLineSinkAsync<F, Fut>

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

pub fn new(f: F) -> Self

Creates a new sink that awaits f once for each parsed line.

Trait Implementations

impl<F, Fut> AsyncLineSink for InspectLineSinkAsync<F, Fut>

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

type Output = ()

Final value produced once the adapter is finished.

fn on_line<'a>( &'a mut self, line: Cow<'a, str>, ) -> impl Future<Output = Next> + Send + 'a

Asynchronously observes a single parsed line. Return Next::Break to stop further parsing.

fn into_output(self) -> Self::Output

Consumes the sink and returns its final output.

fn on_gap(&mut self)

Synchronous gap hook; default no-op. See LineSink::on_gap.

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

Asynchronous EOF hook; default no-op. Invoked after the adapter has flushed any trailing line through on_line.