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

标签 java reactive-programming reactivex reactive-streams rx-java2

如何在 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/

相关文章:

java - 在 Java 中使用 BigIntegers 进行 BitShifting

reactive-programming - 谁在响应式 Web 应用程序中调用 Flux 或 Mono 订阅

java - RxJava Observable 最短执行时间

java - 如何创建订阅可观察对象的BehaviorSubject?

swift - 是否有一个 Observable 的首选类型而不需要在 Next 事件中有一个值?

java - 在Java中使用Elasticsearch的NoClassDefFoundError

JBoss 和 Quartz 上的 Java 堆空间停止运行

java - Eclipse 错误 : "Failed to connect to remote VM"

javascript - 如何使用 React 创建 “twitter like” 剩余字符数

c# - Reactive Extensions 中的 SequenceEqual 如何工作