DelaySnapshotStore

class DelaySnapshotStore(delaySupplier: () -> Duration = { Duration.ofMillis(5) }, val delegate: SnapshotStore = InMemorySnapshotStore()) : SnapshotStore, Decorator<SnapshotStore>

Constructors

constructor(delaySupplier: () -> Duration = { Duration.ofMillis(5) }, delegate: SnapshotStore = InMemorySnapshotStore())

open override val name: String

open fun getVersion(aggregateId: AggregateId): Mono<Int>

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

open override fun <S : Any> save(snapshot: Snapshot<S>): Mono<Void>