Module stream 

WebSocket event-streaming support. Event subscription streaming surfaces.

Re-exports

pub use namespace_filter::GateVerdict;

pub use namespace_filter::NamespaceEventGate;

pub use resume::RESUME_CURSOR_AHEAD_OF_HISTORY;

pub use selector::SubscriptionSelector;

pub use socket::EncodedEventStream;

pub use socket::EncodedFrame;

pub use socket::SEQUENCE_CONTIGUITY_VIOLATION;

pub use socket::forward_subscription;

pub use socket::handle_subscription_socket;

pub use subscribe::EventSubscription;

pub use subscribe::MappedSubscription;

pub use subscribe::map_subscription_request;

pub use subscribe::subscribe_events;

Modules

namespace_filter

Namespace-aware event gating at the broadcast/encode seam. Namespace-aware event gating at the broadcast/encode seam.

resume

Replay/live splice for per-workflow subscription resumption. Replay/live splice for per-workflow subscription resumption.

selector

Server-side workflow-type/status selector filtering. Server-side selector filtering for filtered subscriptions.

socket

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

subscribe

Event subscription request mapping and store subscription helpers. SubscriptionRequest to EventFilter mapping.