CODEWITHSUNDEEP
javareactive-programmingreactivexreactive-streamsrx-java2
caioquirino
caioquirino

Reputation: 365

RxJava 2.0 - How to convert Observable to Publisher

How to convert Observable to Publisher in RxJava version 2?

In the first version we have the https://github.com/ReactiveX/RxJavaReactiveStreams project that do exactly what I need. But How can I do it in RxJava 2?

Upvotes: 22

Views: 15322

Answers (1)

Yaroslav Stavnichiy
Yaroslav Stavnichiy

Reputation: 21446

Use the following code:

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

As Observable does not implement backpressure, you need to select backpressure strategy when converting. See available choices here.

Or use Flowable instead of Observable in the first place. See here for details.

Upvotes: 30

Related Questions