Skip to main content

Module assemble

Module assemble 

Source
Expand description

Pure page-assembly state machine.

Extracted from the stream so the RECORD/STATE/EOF → StreamPage logic is unit-testable without spawning a process. The stream feeds parsed messages in; the process/error paths (idle timeout, non-zero exit, malformed-fail) stay in stream.rs.

Structs§

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