Trait nakadion::publisher::PublishesEvents

pub trait PublishesEvents {
    fn publish_events<'a, E: Serialize + Sync, T: Into<FlowId>>(
        &'a self, 
        event_type: &'a EventTypeName, 
        events: &'a [E], 
        flow_id: T
    ) -> PublishFuture<'a>;
}

Publish non serialized events.

This trait is implemented for all types which implement PublishesSerializedEvents.

Required methods

fn publish_events<'a, E: Serialize + Sync, T: Into<FlowId>>(
    &'a self,
    event_type: &'a EventTypeName,
    events: &'a [E],
    flow_id: T
) -> PublishFuture<'a>

Loading content...

Implementors

impl<T> PublishesEvents for T where
    T: PublishesSerializedEvents + Send + Sync, 

fn publish_events<'a, E: Serialize + Sync, F: Into<FlowId>>(
    &'a self,
    event_type: &'a EventTypeName,
    events: &'a [E],
    flow_id: F
) -> PublishFuture<'a>

Loading content...