Skip to content
Advertisement

How to convert a Flux<List> to a merged Flux?

While working with Project Reactor, there came a use case where I’d want to convert a Flux <List<String>> to a <Flux<String>> where all those lists are flattened to form a Flux. Is there any out of the box method for the same?

Advertisement

Answer

Use .flatMap(Flux::fromIterable)

List<String> list = new ArrayList<>();
var flux = Flux.just(list)
            .flatMap(Flux::fromIterable);
User contributions licensed under: CC BY-SA
3 People found this is helpful
Advertisement