load

abstract fun <S : Any> load(aggregateId: AggregateId): Mono<Snapshot<S>>

Loads the latest snapshot for the specified aggregate.

Return

a Mono emitting the snapshot or empty if none exists

Parameters

aggregateId

the ID of the aggregate