0

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 项目中找不到所需的功能,扩展项目值得一看

4

1 回答 1

0

从 2.0.5 开始,RxJava 2 现在提供了类似的parallel()API。

于 2017-01-30T15:04:10.747 回答