问题描述
我在 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())