Struct RuntimeEventBridge 

pub struct RuntimeEventBridge { /* private fields */ }

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

The bridge appends each event to the store first; only on a successful append does it publish the envelope to the run room (and, when a session id is known, to the session room). Append failure therefore never produces a live event with an incomplete replay source.

Implementations

impl RuntimeEventBridge

pub fn new( runtime: Arc<AgentRuntime>, event_store: Arc<dyn RuntimeEventStore>, stream_adapter: Arc<dyn RuntimeStreamAdapter>, ) -> Self

Creates a bridge wiring runtime to event_store and stream_adapter.

pub fn spawn(self: Arc<Self>) -> RuntimeEventBridgeHandle

Spawns the background forwarding task and returns a handle.

The task runs until the runtime’s event broadcast closes or the handle is dropped/aborted.