RxJava 库曾经有一个已停产的并行运算符,但是当前的 Spring Reactor 项目有一个并行运算符
是什么阻止了 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 的链接和回复,我想正是这种态度让图书馆对像我这样的人来说很简单。如果您在主 RxJava 项目中找不到所需的功能,扩展项目值得一看