RxJava 2.0 - 如何将Observable转换为Publisher

cai*_*ino 14 java reactive-programming reactive-streams reactivex rx-java2

如何在RxJava版本2中将Observable转换为Publisher?

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

Yar*_*hiy 19

使用以下代码:

Publisher publisher = observable.toFlowable(BackpressureStrategy.XXX);
Run Code Online (Sandbox Code Playgroud)

由于Observable没有实施背压,您需要在转换时选择背压策略.查看可用的选择这里.

或者使用Flowable而不是Observable首先使用.详情请见此处.