[−][src]Struct eventstore::commands::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.
Methods
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: u16) -> Self
[src]
The buffer size to use for the persistent subscription.
pub fn execute(self) -> (PersistentSubRead, PersistentSubWrite)
[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,
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>,