Struct CollectLineSink 

pub struct CollectLineSink<T, F> { /* private fields */ }

LineSink holding the user closure and a sink; on_line calls the closure with the line and a &mut borrow of the sink. Compose with LineAdapter to drive collect_lines, or to build your own custom collect-lines consumer outside the built-in factory methods.

Implementations

impl<T, F> CollectLineSink<T, F>

where T: Sink, F: FnMut(Cow<'_, str>, &mut T) -> Next + Send + 'static,

pub fn new(sink: T, f: F) -> Self

Creates a new sink that calls f with each parsed line and a &mut borrow of sink.

Trait Implementations

impl<T, F> LineSink for CollectLineSink<T, F>

where T: Sink, F: FnMut(Cow<'_, str>, &mut T) -> Next + Send + 'static,

type Output = T

Final value produced once the adapter is finished. Returned via Consumer::wait.

fn on_line(&mut self, line: Cow<'_, str>) -> Next

Invoked for every 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)

Invoked after the adapter resets the parser following a stream gap. The default does nothing; override when the inner sink keeps line-spanning state that the gap invalidates.

fn on_eof(&mut self)

Invoked once the adapter finishes flushing any trailing line at EOF. The default does nothing; override for sinks that want a finalization hook beyond the last on_line call.