sinkSupplier

open override val sinkSupplier: (NamedAggregate) -> Sinks.Many<StateEvent<*>>

sinkSupplier

Supplier for creating sinks for each named aggregate (default: multicast sink with backpressure buffer).