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

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

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