[−][src]Struct eventstore::RegularCatchupSubscribe
Subscribes to a given stream. This kind of subscription specifies a
starting point (by default, the beginning of a stream). For a regular
stream, that starting point will be an event number. For the system
stream $all
, it will be a position in the transaction file
(see subscribe_to_all_from
). This subscription will fetch every event
until the end of the stream, then will dispatch subsequently written
events.
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 subsequenttly written events until such time as the subscription is dropped or closed.
- Notes Catchup subscription are resilient to connection drops. Basically, if the connection drops. The command will restart its catching up phase from the begining and then emit a new volatile subscription request.
All this process happens without the user has to do anything.
Implementations
impl RegularCatchupSubscribe
[src]
pub fn resolve_link_tos(self, tos: LinkTos) -> Self
[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 start_position(self, start_pos: u64) -> Self
[src]
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 will start from the event number 0.
pub fn credentials(self, creds: Credentials) -> Self
[src]
Performs the command with the given credentials.
pub async fn execute(
self
) -> Result<Box<dyn Stream<Item = Result<SubEvent>> + Send + Unpin>>
[src]
self
) -> Result<Box<dyn Stream<Item = Result<SubEvent>> + Send + Unpin>>
Runs the subscription command.
pub async fn execute_event_appeared_only(
self
) -> Result<Box<dyn Stream<Item = Result<ResolvedEvent>> + Send + Unpin>>
[src]
self
) -> Result<Box<dyn Stream<Item = Result<ResolvedEvent>> + Send + Unpin>>
Runs the subscription command. Filter out all subscription events that are not SubEvent::EventAppeared
.
Auto Trait Implementations
impl !RefUnwindSafe for RegularCatchupSubscribe
impl Send for RegularCatchupSubscribe
impl Sync for RegularCatchupSubscribe
impl Unpin for RegularCatchupSubscribe
impl !UnwindSafe for RegularCatchupSubscribe
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>,