Struct EventBus 

pub struct EventBus { /* private fields */ }

Thread-safe async event bus for publish/subscribe pattern

Implementations

impl EventBus

pub fn new() -> Self

Create a new event bus

pub fn arc() -> Arc<Self>

Create a new Arc-wrapped event bus

pub async fn subscribe_async<F, Fut>( &self, channel: &str, handler: F, ) -> Subscriber

where F: Fn(AgentSessionEvent) -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + 'static,

Subscribe to an event channel with an async handler

pub async fn subscribe_sync( &self, channel: &str, handler: SyncEventHandler, ) -> Subscriber

Subscribe to an event channel with a sync handler

pub fn subscribe(&self, channel: &str, handler: SyncEventHandler) -> Subscriber

Subscribe to an event channel (sync version for convenience)

pub async fn publish(&self, channel: &str, event: AgentSessionEvent)

Publish an event to a channel

pub async fn unsubscribe(&self, channel: &str, id: u64)

Unsubscribe a specific handler

pub async fn unsubscribe_all(&self, channel: &str)

Unsubscribe all handlers for a channel

pub async fn clear(&self)

Clear all subscriptions

pub async fn subscription_count(&self) -> usize

Get the number of active subscriptions

Trait Implementations

impl Default for EventBus

fn default() -> Self

Returns the “default value” for a type.