Module socket 

WebSocket frame encoding and subscription forwarding helpers. WebSocket forward loop + lag handling.

Structs

EncodedEventStream

Bounded encoded stream built from an engine subscription.

Constants

SEQUENCE_CONTIGUITY_VIOLATION

error_type discriminator for the per-workflow contiguity tripwire: a delivered-stream sequence gap or regression that should be unreachable under the splice invariants, surfaced loudly instead of delivering a gapped stream.

Functions

forward_subscription

Forward a previously authorized engine subscription to a WebSocket.

handle_subscription_socket

Authorize a wire subscription request and forward it on an accepted socket.

spawn_encoded_event_stream

Spawn the non-blocking engine-reader side of a WebSocket subscription.

Type Aliases

EncodedFrame

Encoded event frame queued for a WebSocket connection.