Struct fmodel_rust::materialized_view::MaterializedView

pub struct MaterializedView<S, E, Repository, View, Error>where
    Repository: ViewStateRepository<E, S, Error>,
    View: ViewStateComputation<E, S>,{ /* private fields */ }

Materialized View.

It is using a View / ViewStateComputation to compute new state based on the current state and the event. It is using a ViewStateRepository to fetch the current state and to save the new state.

Generic parameters:

• S - State
• E - Event
• Repository - View State repository
• View - View
• Error - Error

Implementations

impl<S, E, Repository, View, Error> MaterializedView<S, E, Repository, View, Error>where Repository: ViewStateRepository<E, S, Error>, View: ViewStateComputation<E, S>,

pub fn new(repository: Repository, view: View) -> Self

Creates a new instance of MaterializedView.

pub async fn handle(&self, event: &E) -> Result<S, Error>

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