RxJava 2.0 - Как преобразовать наблюдаемые в издателя

Question

Как преобразовать Observable в Publisher в RxJava версии 2?

В первой версии у нас есть проект https://github.com/ReactiveX/RxJavaReactiveStreams, который выполняет именно то, что мне нужно. Но как я могу сделать это в RxJava 2?

Answer 1

Используйте следующий код:

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

Как Observable не реализует противодавление, вам необходимо выбрать стратегию противодавления при преобразовании. См. Доступные варианты here.

Или используйте Flowable вместо Observable в первую очередь. См. here.