<Reduce emissions of Flux based on value?> I'm hav...

# stackoverflow

[user]

Reduce emissions of Flux based on value?
I'm having following flux:

val myFlux = Flux.fromIterable(listOf("A", "A", "B", "C", "C"))


I would like to map it into Flux where each String would contain AA B CC respectively.

It can be also Flux where each SomeDomainObject would contain same keys (eg. AA)

I cannot use groupBy since number of keys would be huge.