ReactorWebFlux：帮助了解如何工作平面地图（）

Question

请帮助理解我如何在我的例子中使用fkatMap（）：

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

我看了留档。我知道如何工作，但我不明白我需要如何在我的例子中使用。谢谢。

Answer 1

正如Kayaman已经回答的，您可以执行以下操作：

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