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没有实现背压，转换时需要select背压策略。查看可用选项 here.

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