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。