[−][src]Struct eventstore::commands::SubscribeToStream
Represents a volatile subscription. For example, if a stream has 100 events in it when a subscriber connects, the subscriber can expect to see event number 101 onwards until the time the subscription is closed or dropped.
- Notes If the connection drops, the command will not try to resume the subscription. If you need this behavior, use a catchup subscription instead.
Methods
impl<'a> SubscribeToStream<'a>[src]
pub fn credentials(self, value: Credentials) -> SubscribeToStream<'a>[src]
Performs the command with the given credentials.
pub fn resolve_link_tos(self, tos: LinkTos) -> SubscribeToStream<'a>[src]
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 execute(self) -> Subscription[src]
Sends the volatile subscription request to the server asynchronously even if the subscription is available right away.
Auto Trait Implementations
impl<'a> Send for SubscribeToStream<'a>
impl<'a> Sync for SubscribeToStream<'a>
Blanket Implementations
impl<T, U> Into for T where
U: From<T>, [src]
U: From<T>,
impl<T> From for T[src]
impl<T, U> TryFrom 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> Borrow for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut for T where
T: ?Sized, [src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T[src]
impl<T, U> TryInto 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<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,