invoke

open operator override fun invoke(exchange: ServerCommandExchange<*>): Mono<DomainEventStream>