Struct PageAssembler 

pub struct PageAssembler { /* private fields */ }

Accumulates RECORDs into pages and attaches the latest STATE as the page bookmark, per the v0 single-stream rules.

Implementations

impl PageAssembler

pub fn new( target_stream: impl Into<String>, batch_size: usize, flush_on_state: bool, ) -> Self

batch_size == 0 disables size-based flushing (flush only on STATE/EOF).

pub fn on_record(&mut self, stream: &str, record: Value) -> Option<StreamPage>

Feed a RECORD. Records for a different stream are ignored (single-stream v0). Returns a page when the batch_size threshold is reached.

pub fn on_state(&mut self, value: Value) -> Option<StreamPage>

Feed a STATE. Always becomes the pending checkpoint; flushes immediately when flush_on_state (yielding a page — possibly empty — that carries the STATE as its bookmark).

pub fn on_eof(&mut self) -> Option<StreamPage>

Flush any trailing buffer + pending checkpoint at end-of-stream. Returns None when there is nothing to emit.