AggregateTracingReplay
object AggregateTracingReplay
Functions
Link copied to clipboard
fun <S : Any> trace(stateAggregateMetadata: StateAggregateMetadata<S>, stateAggregateFactory: StateAggregateFactory, eventStreams: List<DomainEventStream>): List<StateEvent<ObjectNode>>
fun <S : Any> trace(stateAggregateMetadata: StateAggregateMetadata<S>, stateAggregateFactory: StateAggregateFactory, eventStreams: List<DomainEventStream>, emitHeadVersion: Int, tailVersion: Int): Flux<StateEvent<ObjectNode>>