Struct eventstore::commands::ConnectToPersistentSubscription

pub struct ConnectToPersistentSubscription<'a> { /* fields omitted */ }

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<'a> ConnectToPersistentSubscription<'a>

pub fn credentials(     self,     creds: Credentials ) -> ConnectToPersistentSubscription<'a>

Performs the command with the given credentials.

pub fn batch_size(self, batch_size: u16) -> ConnectToPersistentSubscription<'a>

The buffer size to use for the persistent subscription.

pub fn execute(self) -> Subscription

Sends the persistent subscription connection request to the server asynchronously even if the subscription is available right away.