Struct GenericStreamEncoder 

pub struct GenericStreamEncoder<W: Write> { /* private fields */ }

GenericStreamEncoder writes GCF tabular output incrementally as rows arrive. Zero buffering: each row is written immediately. A trailer summary is emitted on close() with the final counts.

Thread-safe via internal Mutex.

Example

use gcf::GenericStreamEncoder;
use gcf::stream_generic::GcfValue;

let buf = Vec::new();
let enc = GenericStreamEncoder::new(buf);
enc.begin_array("employees", &["id", "name", "department", "salary"]);
enc.write_row(&[1.into(), "Alice".into(), "Engineering".into(), 95000.into()]);
enc.end_array();
enc.close().unwrap();

Implementations

impl<W: Write> GenericStreamEncoder<W>

pub fn new(w: W) -> Self

Create a new streaming encoder for tabular/generic data.

pub fn begin_array(&self, name: &str, fields: &[&str])

Start a tabular array section with deferred count [?].

pub fn write_row(&self, values: &[GcfValue])

Emit a single pipe-separated row immediately.

pub fn end_array(&self)

Close the current array section and record its count.

pub fn write_kv(&self, key: &str, value: &GcfValue)

Emit a key=value line immediately.

pub fn write_section(&self, name: &str)

Start a nested object section (## key).

pub fn write_inline_array(&self, name: &str, values: &[GcfValue])

Emit a primitive array inline: name[N]: val1,val2,val3

pub fn close(&self) -> Result<()>

Emit the ## _summary trailer with final counts.