load
open override fun <S : Any> load(aggregateId: AggregateId, metadata: StateAggregateMetadata<S>, tailVersion: Int): Mono<StateAggregate<S>>
Loads a state aggregate by replaying events up to the specified version. Starts from an empty state and applies all events from the expected next version.
Return
a Mono emitting the loaded state aggregate
Parameters
aggregateId
the ID of the aggregate to load
metadata
metadata for the state aggregate type
tailVersion
the maximum version to load
open override fun <S : Any> load(aggregateId: AggregateId, metadata: StateAggregateMetadata<S>, tailEventTime: Long): Mono<StateAggregate<S>>
Loads a state aggregate by replaying events up to the specified event time. Starts from an empty state and applies all events from the next event time.
Return
a Mono emitting the loaded state aggregate
Parameters
aggregateId
the ID of the aggregate to load
metadata
metadata for the state aggregate type
tailEventTime
the maximum event time to load