java - 如何将 Mono<List<String>> 转换为 Flux<String>

标签 java project-reactor

我正在将用 RxJava 1.x 编写的小项目转换为 Reactor 3.x。一切都很好,只是我找不到如何替换 flatMap(Observable::from)与合适的对手。我有Mono<List<String>>我需要将其转换为 Flux<String> .

最佳答案

在 Reactor 3 中,from 运算符已专门化为几个变体,具体取决于原始源(数组、可迭代等...)。

在你的情况下使用 yourMono.flatMapMany(Flux::fromIterable)

关于java - 如何将 Mono<List<String>> 转换为 Flux<String>,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42007841/

相关文章:

kotlin - Reactor - 如果没有通过过滤器,如何使用 filterWhen 并仍然传递用于记录目的的值?

java - YAJSW 将 jar 作为窗口服务运行的任何替代方案

java - 如何在 Java 富客户端(LGPL、Apache、MIT 许可证)中显示 VNC 查看器?

java - 慢速 Hibernate/C3P0 处理非慢速 Postgres SELECT

java - 不鼓励使用 Mono<Optional<T>> 吗?

java - 如何从 Http 集成流创建 Spring Reactor Flux?

reactive-programming - 使用项目reactor mergeWith()运算符来实现 "if/elseif/else"分支逻辑

java - com.parse.ParseException : bolts. ExecutorException:执行器抛出异常

java - Spring @Required 和 @Mandatory 注解

java - 如何正确使用 Reactor Publisher