Struct EventBus 

pub struct EventBus { /* private fields */ }

Subscribers by event type. See the module docs.

Implementations

impl EventBus

pub fn new() -> EventBus

pub fn subscribe<E, F>(&self, handler: F) -> SubscriptionId

where E: Any, F: Fn(&E) + Send + Sync + 'static,

Call handler with every event of type E published from now on.

pub fn unsubscribe(&self, id: SubscriptionId) -> bool

Stop a subscription; false when it was already gone.

pub fn publish<E>(&self, event: &E) -> usize

where E: Any,

Hand event to every subscriber of its type, in subscription order; returns how many ran to completion.

pub fn subscribers<E>(&self) -> usize

where E: Any,

How many subscribers events of type E have.

pub fn forward_to_mcp<E, F>( &self, server: McpServer, method: &str, params: F, ) -> SubscriptionId

where E: Any, F: Fn(&E) -> String + Send + Sync + 'static,

Send each E to MCP clients as the notification method, with params(event) (a JSON object) as its params (McpServer::notify).

pub fn forward_to_channel<E, T, M>( &self, hub: Hub, topic: T, message: M, ) -> SubscriptionId

where E: Any, T: Fn(&E) -> String + Send + Sync + 'static, M: Fn(&E) -> String + Send + Sync + 'static,

Available on non-WebAssembly only.

Publish each E to the channel topic topic(event) as message(event) (Hub::publish).

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.