Struct ProjectionSubscription 

pub struct ProjectionSubscription<E: Executor, P: Default + 'static> { /* private fields */ }

Builder for a subscription that keeps a Projection auto-updated.

Created via Projection::subscription. On each incoming event, the subscription loads the affected aggregate id through the projection, which in turn re-runs handlers and persists the snapshot.

Implementations

impl<E, P> ProjectionSubscription<E, P>

where E: Executor + Clone + 'static, P: Snapshot<E> + Default + Send + Sync + 'static,

pub fn routing_key(self, v: impl Into<String>) -> Self

Filters events by routing key.

Overrides any executor-level default.

pub fn all(self) -> Self

Processes all events regardless of routing key.

Overrides any executor-level default.

pub fn chunk_size(self, v: u16) -> Self

Sets the number of events to process per batch (default 300).

pub fn retry(self, v: u8) -> Self

Sets the maximum number of retries on failure (default 30).

pub fn no_retry(self) -> Self

Disables retries.

pub fn delay(self, v: Duration) -> Self

Sets a delay before starting the subscription.

pub fn continue_on_error(self) -> Self

Allows the subscription to continue after handler failures.

pub async fn start(self, executor: &E) -> Result<Subscription>

Starts the subscription.

Returns a Subscription handle that can be used for graceful shutdown.