[−][src]Struct eventstore::ConnectToPersistentSubscription
A subscription model where the server remembers the state of the consumption of a stream. This allows for many different modes of operations compared to a regular subscription where the client hols the subscription state.
Implementations
impl ConnectToPersistentSubscription[src]
pub fn credentials(self, creds: Credentials) -> Self[src]
Performs the command with the given credentials.
pub fn batch_size(self, batch_size: i32) -> Self[src]
The buffer size to use for the persistent subscription.
pub async fn execute(self) -> Result<(SubscriptionRead, SubscriptionWrite)>[src]
Sends the persistent subscription connection request to the server asynchronously even if the subscription is available right away.
Auto Trait Implementations
impl !RefUnwindSafe for ConnectToPersistentSubscription
impl Send for ConnectToPersistentSubscription
impl Sync for ConnectToPersistentSubscription
impl Unpin for ConnectToPersistentSubscription
impl !UnwindSafe for ConnectToPersistentSubscription
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,
pub fn borrow_mut(&mut self) -> &mut T[src]
impl<T> From<T> for T[src]
impl<T> Instrument for T[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>[src]
pub fn in_current_span(self) -> Instrumented<Self>[src]
impl<T> Instrument for T[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>[src]
pub 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]
pub 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.
pub 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.
pub 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>,
pub fn vzip(self) -> V
impl<T> WithSubscriber for T[src]
pub fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>, [src]
S: Into<Dispatch>,