handleExchange

open override fun handleExchange(exchange: E): Mono<Void>

Handles a message exchange by processing all events in the stream.

This method iterates through all events in the stream, processes each one, and acknowledges the exchange upon completion.

A Mono that completes when all events are processed

exchange

The message exchange containing the event stream