如何在同一个通量上执行两个操作

问题描述

我有一个项目反应堆 Flux。我想对同一个通量执行两个不同的操作。我想到了下面的方法。但这是按顺序发生的。有没有更好的方法可以让这两个操作并行发生，因为它们是独立的操作

myFlux.reduce(this::operationOne).subscribe(System.out::println);
myFlux.reduce(this::operationTwo).subscribe(System.out::println);

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）