Struct ProjectionHandle 

pub struct ProjectionHandle<P> { /* private fields */ }

Read-only access to a projection’s current state and offset.

P is the user’s projection type (the read model). Cloning a handle is cheap — the underlying state is shared.

Implementations

impl<P: Send + Sync + 'static> ProjectionHandle<P>

pub fn offset(&self) -> u64

Highest journal sequence number the runner has applied. Useful for tests that wait until the projection has caught up.

pub async fn snapshot(&self) -> RwLockReadGuard<'_, P>

Take a read lock on the projection state.

pub async fn read<R>(&self, f: impl FnOnce(&P) -> R) -> R

Apply a closure to the projection state under a read lock and return the result. Convenience wrapper around Self::snapshot.

Trait Implementations

impl<P> Clone for ProjectionHandle<P>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.