[][src]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[src]

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

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>, 
[src]

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

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

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>, 
[src]

Acknowledges a ResolvedEvent has failed during process.

Auto Trait Implementations

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> From<T> for T[src]

impl<T> Instrument for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> IntoRequest<T> for T[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>, 

impl<T> WithSubscriber for T[src]