receive

abstract fun receive(namedAggregates: Set<NamedAggregate>): Flux<E>