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.

The default constructor uses DEFAULT_MAX_LINE_BYTES to guard against an unbounded buffered line on an adversarial stream; exceeding it fails closed with NetError::LineTooLong. unbounded is the explicit opt-out for trusted in-memory inputs.

Implementations

impl NdjsonDecoder

pub fn new() -> Self

Create a decoder using DEFAULT_MAX_LINE_BYTES.

pub fn unbounded() -> Self

Create a decoder with no per-line size limit.

Use this only for trusted, already-bounded inputs.

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.

pub fn flush_checked(&mut self) -> Result<Option<String>, NetError>

Take any buffered remainder as a final record, checking the configured line cap first.

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() -> Self

Returns the “default value” for a type.