safeOnNext

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