Struct MemoryEventBus 

pub struct MemoryEventBus<E>
where
    E: Event,
{ /* private fields */ }

Subscription-order event bus for tests and single-process applications.

Publishing stops and returns the first handler error. It never silently logs and discards a failed handler invocation.

Implementations

impl<E> MemoryEventBus<E>

where E: Event,

pub const fn new() -> Self

Creates an empty event bus.

pub fn subscribe( &self, handler: Arc<dyn EventHandler<E>>, ) -> SoapResult<SubscriptionId>

Adds a handler.

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

Removes a handler and reports whether it existed.

pub fn subscriber_count(&self) -> SoapResult<usize>

Returns the number of current handlers.

Trait Implementations

impl<E> Debug for MemoryEventBus<E>

where E: Event,

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

Formats the value using the given formatter.

impl<E> Default for MemoryEventBus<E>

where E: Event,

fn default() -> Self

Returns the “default value” for a type.

impl<E> EventPublisher<E> for MemoryEventBus<E>

where E: Event,

fn publish(&self, event: EventEnvelope<E>) -> BoxFuture<'_, SoapResult<()>>

Publishes an event to the configured delivery mechanism.