Reactor WebFlux: помогите понять, как работает flatMap ()

Question

Пожалуйста, помогите понять, как я могу использовать fkatMap () в моем примере:

Flux.just("1,2,3", "4,5,6")
                .flatMap(// to do something)
                .collect(Collectors.toList())
                .subscribe(System.out::println);

Я прочитал документацию. Я понял, как работает flatMap (), но не могу понять, как мне нужно использовать в моем примере. Спасибо.

Answer 1

Как уже ответил Каяман, вы можете сделать следующее:

Flux.just("1,2,3", "4,5,6")
        .flatMap(i -> Flux.fromIterable(Arrays.asList(i.split(","))))
        .collect(Collectors.toList())
        .subscribe(System.out::println);