AbstractAggregateEventDispatcher
constructor(messageReadiness: Mono<Void> = Mono.empty(), processingAdmission: () -> Unit = {}, processingQuiescence: () -> Unit = {}, metrics: WowMetrics)
Parameters
messageReadiness
Completes when the message transport can retain new work
processingAdmission
Opens transport processing after dispatcher demand
processingQuiescence
Revokes transport processing before source cancellation
metrics
Instance-scoped metrics recorder for dispatcher operations
Type Parameters
E
The type of message exchange being handled