java - RxJava 2.0 - 如何将 Observable 转换为 Publisher

Question

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

在第一个版本中，我们有https://github.com/ReactiveX/RxJavaReactiveStreams项目，它完全符合我的需要。但是我如何在 RxJava 2 中做到这一点？

Answer 1

使用以下代码：

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

由于Observable没有实现背压，所以转换时需要选择背压策略。在此处查看可用选项。

或者首先使用Flowable而不是Observable。有关详细信息，请参见此处。