如何在 RxJava 版本 2 中将 Observable 转换为 Publisher?
在第一个版本中我们有 https://github.com/ReactiveX/RxJavaReactiveStreams完全满足我需要的项目。 但是我如何在 RxJava 2 中做到这一点呢?
最佳答案
使用以下代码:
Publisher publisher = observable.toFlowable(BackpressureStrategy.XXX);
由于Observable
没有实现背压,转换时需要选择背压策略。查看可用选项 here .
或者首先使用 Flowable
而不是 Observable
。参见 here了解详情。
关于java - RxJava 2.0 - 如何将 Observable 转换为 Publisher,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40877490/