AbstractAggregateEventDispatcher
constructor(messageReadiness: Mono<Void> = Mono.empty(), processingAdmission: () -> Unit = {}, processingQuiescence: () -> Unit = {})
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
Type Parameters
E
The type of message exchange being handled