How to set TimeOut for complete Observer in RXjava - Android?

Question

I have many request merged in Observable, and I need a Timeout Not for every emission but for complete observable in RXjava. Is it Possible??

            Observable
            .merge(listOfObservables).subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new DisposableObserver<Response>() {

                @Override
                public void onNext(@io.reactivex.annotations.NonNull Response response) {
                    
                }

                @Override
                public void onError(@io.reactivex.annotations.NonNull Throwable e) {
                  
                }

                @Override
                public void onComplete() {
                  
                }
            });

akarnokd · Accepted Answer · 2021-05-31 13:18:06Z

1

You could use takeUntil with a delayed error:

Observable
.merge(listOfObservables)
.subscribeOn(Schedulers.io())
.takeUntil(Observable.error(new TimeoutException()).delay(5, TimeUnit.MINUTES, true))
.observeOn(AndroidSchedulers.mainThread())

answered May 31, 2021 at 13:18

akarnokd

70.1k14 gold badges161 silver badges199 bronze badges

Sign up to request clarification or add additional context in comments.

3 Comments

akarnokd Over a year ago

It relays your sequence of items until the given other sequence, in this case a delayed error signal of TimeoutException, happens. This stops the merge and your onError will be called.

DeePanShu Over a year ago

It means an Error observable starts running parallel to my merged observables, if my merged observables not completed within 5 minutes takeUnitl will throw error and ignore remaining observables right??

DeePanShu Over a year ago

Thanks, its working, i learned a new Logic in RxJava Today

Collectives™ on Stack Overflow

How to set TimeOut for complete Observer in RXjava - Android?

1 Answer 1

3 Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

3 Comments

Your Answer

Sign up or log in

Post as a guest

Related