Struct NdjsonFramer 

pub struct NdjsonFramer { /* private fields */ }

Newline-delimited record framing (NDJSON / JSON Lines) as a streaming RecordFramer.

The framer knows nothing about JSON beyond the newline convention NDJSON guarantees — a JSON document never contains an unescaped newline, so every \n is an unambiguous record boundary.

Framing rules (pinned — changing any of them changes record indexes, which is a resume-compatibility break for sources that checkpoint by index):

• Records are split on \n. Exactly one trailing \r is stripped (CRLF input); nothing else is trimmed.
• Lines that are empty or all-ASCII-whitespace are skipped and do not consume a record index.
• An unterminated final line (no closing \n) is a record.

Implementations

impl NdjsonFramer

pub fn new(max_record_bytes: usize) -> NdjsonFramer

A line framer bounding each record at max_record_bytes decoded bytes.

Trait Implementations

impl Debug for NdjsonFramer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl RecordFramer for NdjsonFramer

fn push(&mut self, bytes: &[u8]) -> Result<()>

Feed the next run of decoded bytes.

fn finish(&mut self) -> Result<()>

End of the stream/object: complete an unterminated final record if the format allows one, and validate any end-of-stream structure.

fn pop(&mut self) -> Option<Vec<u8>>

Pop the next completed record, in stream order.

fn decoded_bytes(&self) -> u64

Total decoded bytes fed so far (for metrics).