Reactor WebFlux：帮助理解如何工作 flatMap()

【问题标题】：Reactor WebFlux: help to understand how to work flatMap()Reactor WebFlux：帮助理解如何工作 flatMap()
【发布时间】：2020-02-22 13:01:28
【问题描述】：

请帮助理解我如何在我的示例中使用 fkatMap()：

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

我阅读了文档。我了解如何工作 flatMap() 但我不明白我需要如何在我的示例中使用。谢谢。

【问题讨论】：

String.split(",") 在这里看起来是平面地图操作的不错选择。你能猜到为什么吗？

标签： java spring-webflux project-reactor reactor

【解决方案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);

【讨论】：

你能告诉我在哪里可以练习一些例子吗？当我阅读理论时，一切对我来说都很清楚，但是当我需要编写代码时，我就遇到了困难。我会非常感谢你！
我很高兴听到这个消息：) 我建议您观看 Oleg Dokuka 演讲的视频。他对反应很生气。他还有一本书《Reactive Programming in Spring 5》，里面也有很多例子。
我想你已经意识到这种反应式的东西与我们过去用 Java 做的有点不同。所以完全没关系，你不能马上跳进去。多练习，很快你就会明白。好好编码！