Spring Reactor 和 Netflix RxJava 中的并行运算符

Question

RxJava 库曾经有并行运算符 discontinued , however the current Spring Reactor project has a parallel operator

是什么阻止了 RxJava 实现并行运算符？

我看到有一个名为 RxJavaParallel 的项目正在尝试执行此操作，但我无法理解为什么要以这种方式处理它？当前的 RxJava 实现是否存在固有的设计限制，使其变得更加困难？

更新

我希望得到解决的那种问题

Flowable.range(1, 100)
.parallel(10)
.runOn(Schedulers.io())
.map(v -> httpClient.blockingGet("http://server/item/" + v))
.sequential()
.observeOn(AndroidSchedulers.mainThread())
.subscribe(...);

@akarnokd 指出的 PR 正是我要找的！想知道为什么它不在那里开始:)

更新

感谢@akarnokd 的 link 和回复，我想正是这种态度让图书馆对像我这样的人来说很简单。 extensions project 值得一看，以防你在 RxJava 主项目中找不到你正在寻找的功能

Answer 1

从 2.0.5 开始，RxJava 2 现在提供了类似 parallel() API.

Spring Reactor 和 Netflix RxJava 中的并行运算符

parallel operator in Spring Reactor and Netflix RxJava

project-reactor

rx-java2