Struct eventstore::SubscribeToStreamOptions

pub struct SubscribeToStreamOptions { /* private fields */ }

Implementations

impl SubscribeToStreamOptions

pub fn authenticated(self, credentials: Credentials) -> Self

Performs the command with the given credentials.

pub fn requires_leader(self, requires_leader: bool) -> Self

pub fn deadline(self, deadline: Duration) -> Self

impl SubscribeToStreamOptions

pub fn start_from(self, position: StreamPosition<u64>) -> Self

For example, if a starting point of 50 is specified when a stream has 100 events in it, the subscriber can expect to see events 51 through 100, and then any events subsequently written events until such time as the subscription is dropped or closed.

By default, it’s StreamPosition::End

pub fn resolve_link_tos(self) -> Self

When using projections, you can have links placed into another stream. If you set true, the server will resolve those links and will return the event that the link points to. Default: NoResolution.

pub fn retry_options(self, options: RetryOptions) -> Self

When a disconnection happens, automatically resubscribe to stream changes. When enabled, The client will keep track of the current subscription offset.

Trait Implementations

impl Clone for SubscribeToStreamOptions

fn clone(&self) -> SubscribeToStreamOptions

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for SubscribeToStreamOptions

fn default() -> Self

Returns the “default value” for a type.