safeOnNext

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

Processes a grouped flux of state events for a specific aggregate.

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

Parameters

value

The grouped flux containing state events for one aggregate

See also