Struct StreamingCsvDecoder 

pub struct StreamingCsvDecoder { /* private fields */ }

Push-based CSV decoder. Layers a streaming feed loop on top of the same process_buf byte-level state machine used by the pull-based CsvDecoder. The cell/record state lives on the struct so it persists across feed calls — partial records stay parked until enough bytes arrive to complete them.

Implementations

impl StreamingCsvDecoder

pub fn new() -> StreamingCsvDecoder

pub fn parsed_headers(&self) -> Option<&[CsvHeader]>

Parsed typed headers, surfaced once the first record has been consumed. Useful for the playground’s mapping preview.

Trait Implementations

impl Default for StreamingCsvDecoder

fn default() -> StreamingCsvDecoder

Returns the “default value” for a type.

impl StreamingRowDecoder for StreamingCsvDecoder

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.