RxJava: How to make observable to create on different thread than main thread

Question

I want observable code to run on different thread than main thread. How can I do this, I'm doing like this:

Observable operationObservable = Observable.create(new ObservableOnSubscribe() { @Override public void subscribe(ObservableEmitter e) throws Exception { e.onNext(longRunningOperation()); e.onComplete(); } }) .subscribeOn(Schedulers.io()) // subscribeOn the I/O thread .observeOn(AndroidSchedulers.mainThread());

You can instruct an Observable to send its notifications to observers on a particular Scheduler by means of the ObserveOn operator. by that you can use your Scheduler or class which implements Scheduler to observe — Kathi
– Kathi, Commented Oct 17, 2017 at 14:01
Your example does exactly that. subscribeOn will make sure the body of the ObservableOnSubscribe.subscribe is executing in one of the IO threads of the IO Scheduler. — akarnokd
– akarnokd, Commented Oct 17, 2017 at 14:06

SoroushA · Accepted Answer · 2017-10-17 13:50:36Z

If you need a new thread to run something on you can just use subscribeOn(Schedulers.newThread()).

Another alternative would be to create your own scheduler and executors which is really not necessary for most cases.

Collectives™ on Stack Overflow

RxJava: How to make observable to create on different thread than main thread

1 Answer 1

Comments

Hot Network Questions