send

open override fun send(message: DomainEventStream): Mono<Void>