Trait nakadion::publisher::PublishesSerializedEvents

pub trait PublishesSerializedEvents {
    fn publish_serialized_events<'a>(
        &'a self, 
        event_type: &'a EventTypeName, 
        events: &[Bytes], 
        flow_id: FlowId
    ) -> PublishFuture<'a>;
}

Publishes events that have been serialized before

This trait can be made a trait object

Required methods

fn publish_serialized_events<'a>(
    &'a self,
    event_type: &'a EventTypeName,
    events: &[Bytes],
    flow_id: FlowId
) -> PublishFuture<'a>

Publishes the serialized events.

Implementors

impl<C> PublishesSerializedEvents for Publisher<C> where
    C: PublishApi + Send + Sync + 'static,