开发者社区> 问答> 正文

如何合并一个 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 实现呢?

展开
收起
景凌凯 2020-04-22 17:41:54 1870 0
1 条回答
写回答
取消 提交回答
  • 有点尴尬唉 你要寻找的东西已经被吃掉啦!

    用 reactor.core.publisher.Flux#merge(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends I>>)

    图片.png

    2020-04-22 17:42:11
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载