wow-mock/me.ahoo.wow.eventsourcing.mock/DelayEventStore

DelayEventStore

class DelayEventStore(delaySupplier: () -> Duration = { Duration.ofMillis(5) }, val delegate: EventStore = InMemoryEventStore()) : EventStore, Decorator<EventStore>

Constructors

Link copied to clipboard
constructor(delaySupplier: () -> Duration = { Duration.ofMillis(5) }, delegate: EventStore = InMemoryEventStore())

Properties

Link copied to clipboard
open override val delegate: EventStore

Functions

Link copied to clipboard
open override fun append(eventStream: DomainEventStream): Mono<Void>
Link copied to clipboard
open override fun load(aggregateId: AggregateId, headVersion: Int, tailVersion: Int): Flux<DomainEventStream>
open override fun load(aggregateId: AggregateId, headEventTime: Long, tailEventTime: Long): Flux<DomainEventStream>