RxJava 2.0 - Как преобразовать Observable в Publisher

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

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


java rx-java2 reactive-programming reactivex reactive-streams
person caioquirino    schedule 29.11.2016    source источник
comment
Преобразуйте его в Flowable, поскольку он реализует Publisher.   -  person akarnokd    schedule 30.11.2016

Ответы (1)


arrow_upward
28
arrow_downward

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

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

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

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

person Yaroslav Stavnichiy    schedule 13.01.2017