Struct WaitForLine 

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

LineVisitor that breaks the moment a predicate accepts a line and remembers whether it has matched yet. Compose with ParseLines to build a predicate-driven consumer; the backends’ wait_for_line helpers wrap this same visitor with an additional tokio::time::timeout.

There is no async counterpart. The predicate is a synchronous Fn(Cow<'_, str>) -> bool and has no .await, so an AsyncLineVisitor would not add capability. If you need to react asynchronously when a matching line is observed, await Consumer::wait on this visitor’s consumer and dispatch from there.

Implementations

impl<P> WaitForLine<P>

where P: Fn(Cow<'_, str>) -> bool + Send + '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> LineVisitor for WaitForLine<P>

where P: Fn(Cow<'_, str>) -> bool + Send + '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.