Struct NdjsonDecoder 

pub struct NdjsonDecoder { /* private fields */ }

Incremental newline-delimited JSON decoder.

Each complete line is returned verbatim as one record string (parsing is the caller’s job). A partial final line is buffered until a later push completes it or flush is called. Blank lines are skipped.

An optional per-line size limit guards against an unbounded buffered line on an adversarial stream; exceeding it fails closed with NetError::OversizeBody.

Implementations

impl NdjsonDecoder

pub fn new() -> Self

Create a decoder with no per-line size limit.

pub fn with_max_line_bytes(max_line_bytes: usize) -> Self

Create a decoder that rejects any line (or buffered partial) exceeding max_line_bytes.

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

Append bytes and return completed JSON record strings, skipping blank lines. Fails closed if any completed line or the buffered remainder exceeds the configured limit.

pub fn flush(&mut self) -> Option<String>

Take any buffered remainder as a final record. Returns None when the buffer is empty or holds only whitespace.

Trait Implementations

impl Debug for NdjsonDecoder

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

Formats the value using the given formatter.

impl Default for NdjsonDecoder

fn default() -> NdjsonDecoder

Returns the “default value” for a type.