sinkSupplier

abstract val sinkSupplier: (NamedAggregate) -> Sinks.Many<M>

Supplier function that creates a sink for a given named aggregate.

Implementations should provide this to create appropriate sinks for message distribution.