Module write_stream 

Write headers describe independently framed, chunked audience streams (§15.6).

Structs

PartDecoder

Decode opened chunks of one part in order, retaining only its unfinished frame and previous record identity. The caller stages yielded records until the whole object and signature have been checked. finish checks the declared record count and byte length; frames crossing the part’s end are refused before their allocation.

PartHeader

The plaintext stream boundaries of one audience part.

WriteEncoder

A borrowed write producer. Before emitting, it encodes one record at a time to measure each part’s byte length and construct the header; emitting a part retains at most one record frame and one 64-KiB chunk.

WriteHeaderFrame

The kind-1 header frame; changes and dismissals are separate kind-2 and kind-3 frames.

Functions

decode_plaintext

Decode a plaintext upload-queue value into the database’s in-memory write. Stream consumers can instead use WriteHeaderFrame and PartDecoder.