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

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

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

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

解决方法

您可以将 takeUntil 与延迟的 error 一起使用：

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