Struct LoadBuilder 

pub struct LoadBuilder<E: Executor, P: Default + 'static> { /* private fields */ }

Builder for loading the projection state of a specific aggregate id.

Created via Projection::load. Allows registering related aggregates whose events also feed this projection, then LoadBuilder::execute runs the load.

Implementations

impl<E: Executor, P: Snapshot<E> + Default + 'static> LoadBuilder<E, P>

pub fn aggregate<A: Aggregate>(self, id: impl Into<String>) -> Self

Adds a related aggregate to load events from.

pub fn aggregate_raw( self, aggregate_type: impl Into<String>, id: impl Into<String>, ) -> Self

Adds a related aggregate to load events from (raw aggregate type).

pub async fn execute(&self, executor: &E) -> Result<Option<P>>

Executes the load, returning the rebuilt state.

Returns None if no events exist for the aggregate, or if a tombstone was registered via Projection::tombstone and the corresponding event has been committed for this id. Returns Err if there are too many events to process in one batch.