receive

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