invoke

open operator override fun invoke(exchange: DomainEventExchange<*>): Mono<CommandStream>

Invokes the message function with the given exchange. This is the primary method to execute the function's logic.

the result of the function execution

exchange

the message exchange to process