Struct EventBus 

pub struct EventBus { /* private fields */ }

Thread-safe event bus for inter-agent communication.

Implementations

impl EventBus

pub fn new() -> EventBus

pub async fn on<F>(&self, key: &str, handler: F)

where F: Fn(AgentEvent) + Send + Sync + 'static,

Subscribe to events with a handler function.

pub async fn off(&self, key: &str)

Unsubscribe a handler.

pub async fn emit(&self, event: AgentEvent)

Publish an event to all subscribed handlers and agent subscriptions.

pub async fn subscribe(&self, subscription: EventSubscription)

Register an agent event subscription.

pub async fn unsubscribe(&self, subscription_id: &str) -> bool

Remove an agent event subscription.

pub async fn drain_pending_events(&self, agent_id: &str) -> Vec<AgentEvent>

Drain all pending events for an agent.

pub async fn create_wait_group( &self, id: String, parent_agent_id: String, expected_agent_ids: Vec<String>, )

Create a wait group for after_all semantics.

pub async fn add_to_wait_group(&self, group_id: &str, agent_id: &str)

Add an agent to an existing wait group.

pub async fn get_wait_group(&self, group_id: &str) -> Option<WaitGroup>

Get a wait group by ID.

pub async fn remove_wait_group(&self, group_id: &str)

Remove a wait group.

pub fn all_event_types() -> Vec<&'static str>

Get all event types as strings (for API responses).

Trait Implementations

impl Clone for EventBus

fn clone(&self) -> EventBus

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for EventBus

fn default() -> EventBus

Returns the “default value” for a type.