请帮助您了解如何在示例中使用fkatMap():
Flux.just("1,2,3", "4,5,6")
.flatMap(// to do something)
.collect(Collectors.toList())
.subscribe(System.out::println);
我阅读了文档。我了解了flatMap()的工作方式,但我不明白在示例中需要使用的方式。谢谢。
正如Kayaman已经回答的那样,您可以执行以下操作:
Flux.just("1,2,3", "4,5,6")
.flatMap(i -> Flux.fromIterable(Arrays.asList(i.split(","))))
.collect(Collectors.toList())
.subscribe(System.out::println);