RxJava 2.0 - 如何将观察者转换为发布者

Question

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

在第一个版本中，我们有https://github.com/ReactiveX/RxJavaReactiveStreams项目，正是我所需要的。 但是我怎样才能在RxJava 2中做到这一点？

Answer 1

使用下面的代码：

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

由于Observable没有实现反压，需要转换时选择背压策略。查看可用选项here。

或者首先使用Flowable而不是Observable。详情请参阅here。