Struct TwoLaneEventBus 

pub struct TwoLaneEventBus { /* private fields */ }

In-process two-lane event bus with synchronous and asynchronous handlers.

Sync-lane handlers run inline and preserve InProcessEventBus failure and ordering semantics. Async-lane handlers are handed to a detached in-process carrier so their failures never propagate to the publisher.

Implementations

impl TwoLaneEventBus

pub fn new() -> Self

Create a new two-lane event bus.

pub fn with_async_bus(async_bus: Arc<dyn EventBus>) -> Self

Create a two-lane bus whose async lane uses an external carrier.

pub async fn sync_handler_count(&self) -> usize

Get the number of sync-lane handlers.

pub async fn async_handler_count(&self) -> usize

Get the number of async-lane handlers.

Trait Implementations

impl Clone for TwoLaneEventBus

fn clone(&self) -> TwoLaneEventBus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for TwoLaneEventBus

fn default() -> Self

Returns the “default value” for a type.

impl EventBus for TwoLaneEventBus

fn publish<'life0, 'async_trait>( &'life0 self, events: Vec<Event>, ) -> Pin<Box<dyn Future<Output = EventBusResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Publish events to all subscribed handlers.

fn subscribe<'life0, 'async_trait>( &'life0 mut self, handler: Box<dyn EventHandler>, ) -> Pin<Box<dyn Future<Output = EventBusResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Subscribe an event handler to the bus.