Struct eventstore::AllCatchupSubscribe

pub struct AllCatchupSubscribe { /* fields omitted */ }

Like RegularCatchupSubscribe but specific to the system stream '$all'.

Implementations

impl AllCatchupSubscribe

pub fn resolve_link_tos(self, tos: LinkTos) -> 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 start_position(self, start_pos: Position) -> Self

Starting point in the transaction journal log. By default, it will start at Revision::Start.

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

Performs the command with the given credentials.

pub fn filter(self, filter: FilterConf) -> Self

Filters events or streams based upon a predicate.

pub async fn execute(
    self
) -> Result<Box<dyn Stream<Item = Result<SubEvent>> + Send + Unpin>>

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 async fn execute_event_appeared_only(
    self
) -> Result<Box<dyn Stream<Item = Result<ResolvedEvent>> + Send + Unpin>>

Runs the subscription command. Filter out all subscription events that are not SubEvent::EventAppeared.