[−][src]Struct eventstore::types::PersistentSubWrite
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]
I: Iterator<Item = PersistentSubEvent>,
Acknowledges a batch of ResolvedEvent
s 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]
&'_ 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)
[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]
&'_ mut self,
event: PersistentSubEvent,
action: NakAction,
reason: S
) where
S: AsRef<str>,
Acknowledges a ResolvedEvent
has failed during process.
Auto Trait Implementations
impl !RefUnwindSafe for PersistentSubWrite
impl Send for PersistentSubWrite
impl Sync for PersistentSubWrite
impl Unpin for PersistentSubWrite
impl !UnwindSafe for PersistentSubWrite
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> IntoRequest<T> for T
[src]
fn into_request(self) -> Request<T>
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,
fn vzip(self) -> V
impl<T> WithSubscriber for T
[src]
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,