Module stream 

Structs

BrokerDecisionPayload

Payload for StreamEventKind::BrokerDecision.

QueuePositionPayload

Payload for StreamEventKind::QueuePositionChange.

StreamBus

In-process event bus for max/stream subscriptions. Backed by tokio::sync::broadcast.

StreamEvent

StreamSubscribeParams

StreamSubscribeResult

StreamUnsubscribeParams

StreamUnsubscribeResult

Enums

AdmissionDecision

Admission decision variants pushed via BrokerDecision events.

StreamEventKind

Constants

STREAM_EVENT

STREAM_SUBSCRIBE

STREAM_UNSUBSCRIBE