RxJava 2.0 - How to convert Observable to Publisher

java reactive-programming reactivex reactive-streams rx-java2
caioquirino picture caioquirino · Nov 30, 2016 · Viewed 11.8k times · Source

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?

Answer

Yaroslav Stavnichiy picture Yaroslav Stavnichiy · Jan 13, 2017

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.

Related questions

Combine a list of Observables and wait until all completed

TL;DR How to convert Task.whenAll(List<Task>) into RxJava? My existing code uses Bolts to build up a list of asynchronous tasks and waits until all of those tasks finish before performing other steps. Essentially, it …

Read More
Get the latest value of an Observable and emit it immeditely

I'm trying to get the latest value of a given Observable and get it to emit immediately once it's called. Given the code below as an example: return Observable.just(myObservable.last()) .flatMap(myObservable1 -> { return myObservable1; }) .map(o …

Read More
RxJava - fetch every item on the list

I have a method that returns an Observable<ArrayList<Long>>, which are ids of some Items. I'd like to go through this list and download every Item using another method that returns Observable<Item>. …

Read More