Skip to main content

Module event_forwarder

Module event_forwarder 

Source
Expand description

Event forwarding from MPSC to broadcast channels.

Creates an MPSC channel for agent loop events and spawns a background task that relays events to the session’s broadcast sender while tracking runner diagnostic state (budget events, tool execution, round progress).

Functions§

create_event_forwarder
Create an MPSC channel for agent events and spawn a forwarding task that relays events to the broadcast sender while tracking runner diagnostic fields for live visibility.

Type Aliases§

AccountFeedInbox
Inbox to the account-wide change feed: (session_id, event) before the writer assigns a seq. Threaded as Option so engine-internal callers that have no feed (tests, standalone embeddings) can pass None. Defined here so the engine stays free of any bamboo-server dependency.