sendAndWaitStream
open override fun <C : Any> sendAndWaitStream(command: CommandMessage<C>, waitStrategy: WaitStrategy): Flux<CommandResult>
Sends a command and returns a stream of command results as they become available. This method allows monitoring the progress of command execution in real-time.
Return
A Flux emitting CommandResult instances as they are produced.
Parameters
command
The command message to send.
waitStrategy
The strategy defining how and what to wait for.
Type Parameters
C
The type of the command body.
Throws
if the command is not idempotent.
jakarta.validation.ConstraintViolationException
if validation fails.
if the wait strategy doesn't support void commands when needed.