Struct StateManager 

pub struct StateManager<A: Application> { /* private fields */ }

Implementations

impl<A: Application> StateManager<A>

pub fn state(&self) -> ManagedState<A>

pub async fn commit<T>( &self, transaction: T, ) -> Result<Receipt, Error<T::Error>>

where T: Transaction<A::State> + Into<A::Transaction>, T::Error: From<<<A as Application>::Transaction as Transaction<<A as Application>::State>>::Error>,

pub async fn commit_keyed<T>( &self, key: RequestKey, transaction: T, ) -> Result<Receipt, Error<T::Error>>

where T: Transaction<A::State> + Into<A::Transaction>, T::Error: From<<<A as Application>::Transaction as Transaction<<A as Application>::State>>::Error>,

pub fn decode_transaction( &self, id: &DefinitionId, version: u32, bytes: &[u8], ) -> Result<A::Transaction, DecodeError>

pub async fn query<X>( &self, after: Position, ) -> impl Iterator<Item = Result<Entry<X>, Error>>

where X: Clone + Send + 'static,

pub async fn query_through<X>( &self, after: Position, through: Position, ) -> impl Iterator<Item = Result<Entry<X>, Error>>

where X: Clone + Send + 'static,

pub fn watch<X>( &self, after: Position, ) -> impl Stream<Item = Result<Entry<X>, Error>>

where X: Clone + Send + 'static,

pub fn applied(&self) -> Position

pub fn stored(&self) -> Position

pub async fn wait_until_stored(&self, at: Position)

pub async fn undo( &self, principal: PrincipalId, focus: Focus<A>, ) -> Result<Receipt, Error<<<A as Application>::Transaction as Transaction<<A as Application>::State>>::Error>>

pub async fn redo( &self, principal: PrincipalId, focus: Focus<A>, ) -> Result<Receipt, Error<<<A as Application>::Transaction as Transaction<<A as Application>::State>>::Error>>

pub async fn reversals( &self, principal: PrincipalId, focus: Focus<A>, ) -> Result<At<Reversals>, Error>

pub fn as_principal(&self, principal: PrincipalId) -> Self

pub fn caused_by(&self, cause: Position) -> Self

pub async fn wait_until_captured( &self, through: Position, ) -> Result<(), CaptureError>

pub fn capture_status(&self) -> Result<(), CaptureError>

Trait Implementations

impl<A: Application> Clone for StateManager<A>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.