Struct EventBus 

pub struct EventBus<E: Event> { /* private fields */ }

A bounded, typed, in-process publish/subscribe bus for event E.

This bus is constructor-injected and process-local. Use rskit-messaging for broker-backed cross-process events.

Implementations

impl<E: Event> EventBus<E>

pub fn new(config: EventBusConfig) -> Self

Create a new bounded bus.

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

Publish an event to all current subscribers.

Returns the number of subscribers that accepted the event. Publishing to a bus with no subscribers succeeds and returns 0.

pub fn subscribe(&self) -> Subscriber<E>

Register a new subscriber.

Trait Implementations

impl<E: Event> Clone for EventBus<E>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E: Event> Debug for EventBus<E>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.