RxJava 2.0 - ObservableをPublisherに変換する方法

Question

ObservableをRxJavaバージョン2のPublisherに変換するにはどうすればよいですか？

最初のバージョンでは、私が必要とするものを正確に実行するhttps://github.com/ReactiveX/RxJavaReactiveStreamsプロジェクトがあります。 しかし、RxJava 2でどうすればいいですか？

Answer 1

次のコードを使用します。背圧を実装していないObservableとして

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

を、あなたが変換するとき背圧戦略を選択する必要があります。利用可能な選択肢を参照してくださいhere。

Observableの代わりにFlowableを使用してください。詳細は、hereを参照してください。