[−][src]Trait nakadion::publisher::PublishesSerializedEvents
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>
&'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,
[src]
C: PublishApi + Send + Sync + 'static,
fn publish_serialized_events<'a>(
&'a self,
event_type: &'a EventTypeName,
events: &[Bytes],
flow_id: FlowId
) -> PublishFuture<'a>
[src]
&'a self,
event_type: &'a EventTypeName,
events: &[Bytes],
flow_id: FlowId
) -> PublishFuture<'a>