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

或者首先使用 Flowable 而不是 Observable。参见 here了解详情。