<Reactive Stream: merge flux data into for loop> I...

# stackoverflow

[rss]

Reactive Stream: merge flux data into for loop
I have the readEvents function witch returns an event flux, in the below code i tried to merge all the events, so i used mergeWith, but the allEventFlux always returns empty
val ids = repository.findIds().map { it.ekycId }
val allEventFlux = Flux.empty()
for (id in ids) {
val events: Flux = eventStore.readEvents(id)
allEventFlux.mergeWith(events)
}