Module subscription 

Coordination layer combining replay and live fanout.

RuntimeSubscriptionHub stitches RuntimeEventStore (authoritative replay) together with RuntimeStreamAdapter (best-effort live fanout) so a reconnecting client can receive replay first and then drain live.

RuntimeEventBridge drains AgentRuntime::subscribe into the store+adapter pair: every event is appended first, and only on success is it published to the run (and, when known, session) room. Per the at-least-once contract, consumers deduplicate via RuntimeEventEnvelope::event_id or seq.

Structs

RuntimeEventBridge

Drains AgentRuntime::subscribe into the event store and stream adapter.

RuntimeEventBridgeHandle

Handle to a running RuntimeEventBridge task.

RuntimeSubscription

Replay page plus a live stream for a single subscription.

RuntimeSubscriptionHub

Combines replay and live fanout for runtime event streams.

Enums

RuntimeEventBridgeError

Errors surfaced by a RuntimeEventBridge handle.

RuntimeSubscriptionError

Errors raised while assembling a RuntimeSubscription.