[−][src]Struct eventstore::commands::AllCatchupSubscribe
Like RegularCatchupSubscribe
but specific to the system stream '$all'.
Methods
impl<'a> AllCatchupSubscribe
[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 require_master(self, require_master: bool) -> Self
[src]
Asks the server receiving the command to be the master of the cluster
in order to perform the write. Default: false
.
pub fn start_position(self, start_pos: Position) -> Self
[src]
Starting point in the transaction journal log. By default, it will start at
types::Position::start
.
pub fn credentials(self, creds: Credentials) -> Self
[src]
Performs the command with the given credentials.
pub fn execute(self) -> impl Stream<Item = ResolvedEvent> + Send + Unpin
[src]
Preforms the catching up phase of the subscription asynchronously. When it will reach the head of stream, the command will emit a volatile subscription request.
pub fn execute_with_sub_events(
self
) -> impl Stream<Item = SubEvent> + Send + Unpin
[src]
self
) -> impl Stream<Item = SubEvent> + Send + Unpin
Same as execute
but yields types::SubEvent
instead. Useful if you want to be notified
when a subscription has been confirmed or dropped by the server for example.
Auto Trait Implementations
impl !RefUnwindSafe for AllCatchupSubscribe
impl Send for AllCatchupSubscribe
impl Sync for AllCatchupSubscribe
impl Unpin for AllCatchupSubscribe
impl !UnwindSafe for AllCatchupSubscribe
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>,