首页 ❯

RxJava 2.0 - 如何将 Observable 转换为 Publisher

java reactive-programming rx-java2 reactive-streams reactivex
2022-09-02 03:47:38

如何在RxJava版本2中将可观察转换为发布者？

在第一个版本中，我们有 https://github.com/ReactiveX/RxJavaReactiveStreams 项目，完全可以满足我的需求。但是我该如何在RxJava 2中做到这一点呢？


答案 1

使用以下代码：

Publisher publisher = observable.toFlowable(BackpressureStrategy.XXX);

由于不实现背压，因此在转换时需要选择背压策略。在此处查看可用选项。Observable

或者首先使用而不是使用。有关详细信息，请参阅此处。FlowableObservable


答案 2

推荐
更多 »
标签
更多 »
php pass-by-reference optional-parameters default-value javascript arrays dom function string object serialization tostring visibility syntax jslint use-strict operators equality equality-operator identity-operator datetime timestamp date-arithmetic redirect angularjs loops foreach iteration scope variables
推荐
更多 »