aion_server/stream/
mod.rs

1//! Event subscription streaming surfaces.
2
3/// Namespace-aware event gating at the broadcast/encode seam.
4pub mod namespace_filter;
5/// Replay/live splice for per-workflow subscription resumption.
6pub mod resume;
7/// Server-side workflow-type/status selector filtering.
8pub mod selector;
9/// WebSocket frame encoding and subscription forwarding helpers.
10pub mod socket;
11/// Event subscription request mapping and store subscription helpers.
12pub mod subscribe;
13
14pub use namespace_filter::{GateVerdict, NamespaceEventGate};
15pub use resume::RESUME_CURSOR_AHEAD_OF_HISTORY;
16pub use selector::SubscriptionSelector;
17pub use socket::{
18    EncodedEventStream, EncodedFrame, SEQUENCE_CONTIGUITY_VIOLATION, forward_subscription,
19    handle_subscription_socket,
20};
21pub use subscribe::{
22    EventSubscription, MappedSubscription, map_subscription_request, subscribe_events,
23};
aion_server/stream/mod.rs

aion_server/stream/
mod.rs
