Struct WaitForLineSink 

pub struct WaitForLineSink<P> { /* private fields */ }

LineSink that breaks the moment a predicate accepts a line and remembers whether it has matched yet. Compose with LineAdapter to drive wait_for_line, or to build your own custom predicate-driven consumer outside the built-in factory methods.

Implementations

impl<P> WaitForLineSink<P>

where P: Fn(Cow<'_, str>) -> bool + Send + Sync + 'static,

pub fn new(predicate: P) -> Self

Creates a new sink that breaks the parser the first time predicate returns true.

Trait Implementations

impl<P> LineSink for WaitForLineSink<P>

where P: Fn(Cow<'_, str>) -> bool + Send + Sync + 'static,

type Output = bool

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.