RxJava 2.0 - 如何转换可观察到出版商

caioquirino:

如何可观察转换为出版商RxJava 2版本?

在第一个版本,我们有https://github.com/ReactiveX/RxJavaReactiveStreams项目,做的正是我需要的。但是,我怎么能做到这一点的RxJava 2?

雅罗斯拉夫Stavnichiy:

使用下面的代码:

Publisher publisher = observable.toFlowable(BackpressureStrategy.XXX);

由于Observable没有实现反压,需要转换时选择背压策略。查看可用的选择这里

或者使用Flowable,而不是Observable摆在首位。这里了解详情。

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章