Skip to main content

create_event_forwarder

bamboo_engine::runtime::execution::event_forwarder

Function create_event_forwarder 

Source 
pub fn create_event_forwarder(
    session_id: String,
    broadcast_tx: Sender<AgentEvent>,
    runners: Arc<RwLock<HashMap<String, AgentRunner>>>,
) -> (Sender<AgentEvent>, JoinHandle<()>)
Expand description

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.

Returns (mpsc_tx, forwarder_handle).