Struct MemoryTransactionalProjection 

pub struct MemoryTransactionalProjection<E, S, F> { /* private fields */ }

In-memory reference projection with an atomic read-model/checkpoint boundary.

The update closure receives a cloned candidate read model. The candidate and checkpoint become visible together only when the closure succeeds.

Implementations

impl<E, S, F> MemoryTransactionalProjection<E, S, F>

pub fn new(id: ProjectionId, read_model: S, apply: F) -> Self

Creates a projection from its stable identity, initial model, and update function.

impl<E, S, F> MemoryTransactionalProjection<E, S, F>

where S: Clone,

pub fn snapshot(&self) -> SoapResult<(S, Option<GlobalPosition>)>

Returns a consistent copy of the read model and its checkpoint.

Trait Implementations

impl<E, S, F> Debug for MemoryTransactionalProjection<E, S, F>

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<E, S, F> TransactionalProjection<E> for MemoryTransactionalProjection<E, S, F>

where E: DomainEvent, S: Clone + Send, F: Fn(&mut S, &RecordedEvent<E>) -> SoapResult<()> + Send + Sync,

fn id(&self) -> &ProjectionId

Returns the stable projection identity.

fn checkpoint(&self) -> BoxFuture<'_, SoapResult<Option<GlobalPosition>>>

Loads the last atomically committed global position.

fn project_and_checkpoint<'a>( &'a self, event: &'a RecordedEvent<E>, ) -> BoxFuture<'a, SoapResult<ProjectionApplyOutcome>>

Applies one event and advances its checkpoint in the same transaction.