Module wire_stream 

Newline-delimited streaming frames for the public OCLA wire contract.

Structs

StreamConfig

Runtime limits for one OCLA stream.

Enums

StreamFrame

One newline-delimited message in an OCLA stream.

Functions

decode_frame

Decodes one newline-delimited JSON record into a stream frame.

encode_frame

Encodes one stream frame as a newline-delimited JSON record.

validate_deadline

Rejects a stream whose absolute deadline has passed.