Struct StreamBus 

pub struct StreamBus<B: StreamBackend> { /* private fields */ }

Implementations

impl<B: StreamBackend> StreamBus<B>

pub fn new( backend: Arc<B>, options: StreamBusOptions, ) -> Result<Self, EventBusError>

pub async fn publish( &self, msg: Message, opts: PublishOptions, ) -> Result<MessageId, EventBusError>

pub async fn publish_batch( &self, msgs: Vec<Message>, opts: PublishOptions, ) -> Result<BatchOutcome, EventBusError>

pub async fn subscribe<H>( &self, cfg: SubscriptionConfig, handler: H, ) -> Result<StreamSubscription, EventBusError>

where H: Handler + 'static,

Convenience: subscribe with a concrete handler value, returning a concrete StreamSubscription (not the trait object). For dyn dispatch use the Subscriber trait directly.

Trait Implementations

impl<B: StreamBackend> Clone for StreamBus<B>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<B: StreamBackend> Publisher for StreamBus<B>

fn publish( &self, msg: Message, opts: PublishOptions, ) -> BoxFuture<'_, Result<MessageId, EventBusError>>

fn publish_batch( &self, msgs: Vec<Message>, opts: PublishOptions, ) -> BoxFuture<'_, Result<BatchOutcome, EventBusError>>

impl<B: StreamBackend> Subscriber for StreamBus<B>

fn subscribe( &self, cfg: SubscriptionConfig, handler: Arc<dyn Handler>, ) -> BoxFuture<'_, Result<Arc<dyn Subscription>, EventBusError>>