作者热门文章
- Java 双重比较
- java - 比较器与 Apache BeanComparator
- Objective-C 完成 block 导致额外的方法调用?
- database - RESTful URI 是否应该公开数据库主键?
如何在 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/
我是一名优秀的程序员,十分优秀!