如何在 RXjava 中为完整的观察者设置超时 - Android？

Question

我在 Observable 中合并了很多请求，我需要一个超时 不是针对每个发射，而是针对 RXjava 中的完整可观察。可能吗？？

            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() {
                  
                }
            });

Answer 1

您可以使用 takeUntil 延迟 error:

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

如何在 RXjava 中为完整的观察者设置超时 - Android？

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

android

timeout

rx-java2