wow-core/me.ahoo.wow.event/AbstractEventDispatcher/StateEventDistributionSubscriber/safeOnNext

safeOnNext

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