如何可观察转换为出版商RxJava 2版本?
在第一个版本,我们有https://github.com/ReactiveX/RxJavaReactiveStreams项目,做的正是我需要的。但是,我怎么能做到这一点的RxJava 2?
使用下面的代码:
Publisher publisher = observable.toFlowable(BackpressureStrategy.XXX);
由于Observable没有实现反压,需要转换时选择背压策略。查看可用的选择这里。
Observable
或者使用Flowable,而不是Observable摆在首位。见这里了解详情。
Flowable
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
点击生成二维码
我来说两句