Struct StreamingJsonlDecoder 

pub struct StreamingJsonlDecoder { /* private fields */ }

Push-based JSONL decoder. Accumulates bytes between calls to Self::feed, splits on \n, parses each completed line as a JSON object, and queues the resulting record for Self::drain.

Implementations

impl StreamingJsonlDecoder

pub fn new() -> StreamingJsonlDecoder

Trait Implementations

impl Default for StreamingJsonlDecoder

fn default() -> StreamingJsonlDecoder

Returns the “default value” for a type.

impl StreamingRowDecoder for StreamingJsonlDecoder

fn feed(&mut self, chunk: &[u8]) -> Result<(), Error>

Append a chunk of bytes to the internal buffer and parse any records that became complete. Idempotent: feeding zero bytes is a no-op.

fn drain(&mut self) -> Result<Vec<Vec<(String, LoraValue)>>, Error>

Pull all records completed since the previous drain / finish call. Returns an empty Vec when no full record has been parsed yet.

fn finish(&mut self) -> Result<Vec<Vec<(String, LoraValue)>>, Error>

Signal that no more bytes will be fed. Returns any records emitted by handling the residual buffer — for JSONL/CSV this covers the case where the file ends without a trailing newline.

fn header(&self) -> Option<&[String]>

Column names declared in the file header. Populated after the first record arrives for CSV; always None for JSONL.

fn bytes_fed(&self) -> u64

Total bytes accepted via feed since construction. Used for progress reporting.

fn rows_emitted(&self) -> u64

Total records emitted via drain + finish so far.

fn set_permissive(&mut self, on: bool)

Switch the decoder into permissive mode. In permissive mode, per-record parse failures are accumulated for retrieval via Self::take_errors instead of bubbling out of feed / finish. Fatal errors (encoding issues that desync the byte stream itself) still bubble. Must be called before the first feed; later calls take effect at the next record boundary. Default impl is a no-op for decoders that don’t support it.

fn take_errors(&mut self) -> Vec<RowParseError>

Drain the parse errors accumulated since the previous call. Empty when permissive mode is off or no failures occurred.