Struct StreamingJsonArrayDecoder 

pub struct StreamingJsonArrayDecoder { /* private fields */ }

Push-based JSON-array decoder. Tracks brace/bracket depth and JSON string state byte-by-byte so the input can be fed in arbitrarily sized chunks. Memory bound: at most one in-progress record (between its opening { and matching }) plus a single chunk of incoming bytes.

Implementations

impl StreamingJsonArrayDecoder

pub fn new() -> StreamingJsonArrayDecoder

Trait Implementations

impl Default for StreamingJsonArrayDecoder

fn default() -> StreamingJsonArrayDecoder

Returns the “default value” for a type.

impl StreamingRowDecoder for StreamingJsonArrayDecoder

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.