如何解决如何在同一个通量上执行两个操作
我有一个项目反应堆 Flux。我想对同一个通量执行两个不同的操作。我想到了下面的方法。但这是按顺序发生的。有没有更好的方法可以让这两个操作并行发生,因为它们是独立的操作
myFlux.reduce(this::operationOne).subscribe(System.out::println);
myFlux.reduce(this::operationTwo).subscribe(System.out::println);
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。