Struct DataRowEmitter 

#[non_exhaustive]
pub struct DataRowEmitter { /* private fields */ }

Stateful emitter that assigns per-stream sequence numbers and tracks the running row count for the terminal StreamSummary.

Implementations

impl DataRowEmitter

pub fn next( &mut self, stream: impl Into<String>, payload: Box<RawValue>, ) -> DataRow

Allocate the next DataRow for stream, advancing the per-stream sequence and the overall count.

pub fn count(&self) -> u64

Total rows emitted across all streams.

pub fn per_stream_counts(&self) -> BTreeMap<String, u64>

Snapshot of per-stream row counts.

Trait Implementations

impl Debug for DataRowEmitter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for DataRowEmitter

fn default() -> DataRowEmitter

Returns the “default value” for a type.