createConnection

open override fun createConnection(aggregateId: AggregateId): Publisher<out Connection>