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>, Decider: StateComputation<C, S, E>,

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.