Struct eventstore::types::PersistentSubWrite

pub struct PersistentSubWrite { /* fields omitted */ }

Write part of a persistent subscription. Used to either acknowledge or report error on a persistent subscription.

Methods

impl PersistentSubWrite

pub async fn ack_events<'_, I>(&'_ mut self, events: I) where
    I: Iterator<Item = PersistentSubEvent>, 

Acknowledges a batch of ResolvedEvents has been processed successfully.

pub async fn nak_events<'_, I, S>(
    &'_ mut self,
    events: I,
    action: NakAction,
    reason: S
) where
    I: Iterator<Item = PersistentSubEvent>,
    S: AsRef<str>, 

Acknowledges a batch of ResolvedEvent's has failed during process.

pub async fn ack_event<'_>(&'_ mut self, event: PersistentSubEvent)

Acknowledges a ResolvedEvent has been processed successfully.

pub async fn nak_event<'_, S>(
    &'_ mut self,
    event: PersistentSubEvent,
    action: NakAction,
    reason: S
) where
    S: AsRef<str>, 

Acknowledges a ResolvedEvent has failed during process.