如何合并一个 List<Flux<T>> 中的多个 Flux<T>
请教一下大家一个关于 spring-webfux 得问题，要是我有两个 service 方法 都返回 Flux 我该怎么合并这个结果呢 我尝试了一下把所有 service 返回的 Flux 放到了一个 List 里，然后 foreach 这个 List ，同时在循环外层建了一个 Flux.empty() ，把每次循环结果 merge 到这个 empty 上， 试了一下发现不行，idea 告诉我不能这么玩，说 Flux 每回操作符返回一个新实例所以不能这么玩，那么该怎么合并呢，还是说我用循环这种写法根本不对啊。 Google 了一下也没找到答案，感觉写的好别扭？我是想在一个 Handler 里调用一串 Service 也就是 Handler 中接收到的请求参数同时给若干个 Service 同时处理，像这种场景该如何用 webflux 实现呢？
展开
收起
1
条回答
写回答
写回答
-
有点尴尬唉 你要寻找的东西已经被吃掉啦！用 reactor.core.publisher.Flux#merge(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends I>>)
2020-04-22 17:42:11赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
