FCQRSFCQRS

IProjectionType

PackageFCQRS
A transactional projection and its request-scoped notification subscriptions. Catch-up covers every persistence ID in one committed journal snapshot. It does not wait for other projections, later writes, or external effects.

Specification

Kind
Type
Members
3
Examples
0
CatchUpAsyncSignature
this.CatchUpAsync
CatchUpAsyncSignature
this.CatchUpAsync
CompletionSignature
this.Completion

Summary

NameSignatureSynopsis
CatchUpAsyncthis.CatchUpAsyncCaptures a fixed journal snapshot and waits for this projection to commit every event through it.
CatchUpAsyncthis.CatchUpAsyncCaptures a fixed journal snapshot and waits for this projection to commit every event through it.
Completionthis.CompletionCompletes on disposal or actor-system shutdown; faults on a projection error.

CatchUpAsync

this.CatchUpAsync
Member
Captures a fixed journal snapshot and waits for this projection to commit every event through it. Cancellation/timeout stops the caller's wait, not a transaction already being processed. Call after the aggregate persistence acknowledgement. The caller's ambient TransactionScope is suppressed; projection commits are independent.

Parameters

NameTypeDescription
cancellationTokenCancellationToken

Returns

Task

CatchUpAsync

this.CatchUpAsync
Member
Captures a fixed journal snapshot and waits for this projection to commit every event through it. Uses the configured CatchUpTimeout.

Returns

Task

Completion

this.Completion
Member
Completes on disposal or actor-system shutdown; faults on a projection error. After an error, restart the projection after correcting its cause.

Returns

Task