safeOnNext

open override fun safeOnNext(value: GroupedFlux<MaterializedNamedAggregate, EventStreamExchange>)

Processes a grouped flux of event streams for a specific aggregate.

Creates a new aggregate event dispatcher and starts processing events for the aggregate represented by the group key.

Parameters

value

The grouped flux containing event streams for one aggregate

See also