Struct LineAdapter 

pub struct LineAdapter<S> { /* private fields */ }

Adapter that drives LineParser over chunk events and dispatches every emitted line to the inner LineSink (sync) or AsyncLineSink (async).

One struct, two trait impls: StreamVisitor when S: LineSink, AsyncStreamVisitor when S: AsyncLineSink. Rust selects the right impl from the inner sink’s type at the call site.

Implementations

impl<S> LineAdapter<S>

pub fn new(options: LineParsingOptions, inner: S) -> Self

Creates a new line adapter.

Panics

Panics if options.max_line_length is zero. See LineParsingOptions::max_line_length for the rationale; pass crate::NumBytes::MAX for effectively-unbounded line parsing.

Trait Implementations

impl<S: AsyncLineSink> AsyncStreamVisitor for LineAdapter<S>

Async impl of the same LineAdapter struct.

Each per-line iteration calls next_line synchronously, materializes the line as a fresh String via Cow::into_owned, drops the parser borrow, then awaits the inner sink. The allocation per line is the price of supporting async per-line callbacks on stable Rust — holding a parser borrow across an .await is forbidden because the next iteration re-borrows the parser.

type Output = <S as AsyncLineSink>::Output

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

async fn on_chunk(&mut self, chunk: Chunk) -> Next

Asynchronously observes a single chunk.

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.

async fn on_eof(&mut self)

Asynchronously observes end-of-stream.

fn into_output(self) -> Self::Output

Consumes the visitor and returns its final output.

impl<S: LineSink> StreamVisitor for LineAdapter<S>

type Output = <S as LineSink>::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) -> Next

Invoked for every chunk observed on the stream.

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)

Invoked exactly once when the stream ends (EOF or write side dropped).

fn into_output(self) -> Self::Output

Consumes the visitor and returns its final output.