createConnection

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