Struct lib::events::NatsEventBus

pub struct NatsEventBus { /* private fields */ }

Implementations

impl NatsEventBus

pub fn new(consumer_group: String, client: Client) -> NatsEventBus

Trait Implementations

impl Publisher for NatsEventBus

fn publish<'life0, 'life1, 'async_trait>(
    &'life0 self,
    events: &'life1 [Event]
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

impl Subscriber for NatsEventBus

fn subscribe<'life0, 'life1, 'async_trait>(
    &'life0 self,
    subject: Cow<'life1, str>,
    handler: Box<dyn Handler>
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,