safeOnNext

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