Struct fmodel_rust::aggregate::StateStoredAggregate

pub struct StateStoredAggregate<C, S, E, Repository, Decider, Version, Error>
where
    Repository: StateRepository<C, S, Version, Error>,
    Decider: StateComputation<C, S, E>,
{ /* private fields */ }

State Stored Aggregate.

It is using a Decider / StateComputation to compute new state based on the current state and the command. It is using a StateRepository to fetch the current state and to save the new state.

Generic parameters:

• C - Command
• S - State
• E - Event
• Repository - State repository
• Decider - State computation
• Version - Version
• Error - Error

Implementations

impl<C, S, E, Repository, Decider, Version, Error> StateStoredAggregate<C, S, E, Repository, Decider, Version, Error>

where Repository: StateRepository<C, S, Version, Error> + Sync, Decider: StateComputation<C, S, E> + Sync, C: Sync, S: Sync, E: Sync, Version: Sync, Error: Sync,

pub fn new(repository: Repository, decider: Decider) -> Self

Creates a new instance of StateStoredAggregate.

pub async fn handle(&self, command: &C) -> Result<(S, Version), Error>

Handles the command by fetching the state from the repository, computing new state based on the current state and the command, and saving the new state to the repository.

Trait Implementations

impl<C, S, E, Repository, Decider, Version, Error> StateComputation<C, S, E> for StateStoredAggregate<C, S, E, Repository, Decider, Version, Error>

where Repository: StateRepository<C, S, Version, Error>, Decider: StateComputation<C, S, E>,

fn compute_new_state(&self, current_state: Option<S>, command: &C) -> S

Computes new state based on the current state and the command.

impl<C, S, E, Repository, Decider, Version, Error> StateRepository<C, S, Version, Error> for StateStoredAggregate<C, S, E, Repository, Decider, Version, Error>

where Repository: StateRepository<C, S, Version, Error> + Sync, Decider: StateComputation<C, S, E> + Sync, C: Sync, S: Sync, E: Sync, Version: Sync, Error: Sync,

fn fetch_state<'life0, 'life1, 'async_trait>( &'life0 self, command: &'life1 C ) -> Pin<Box<dyn Future<Output = Result<Option<(S, Version)>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Fetches current state, based on the command.

fn save<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, state: &'life1 S, version: &'life2 Option<Version> ) -> Pin<Box<dyn Future<Output = Result<(S, Version), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Saves state.