相关疑难解决方法(0)

我的用例如下：

我创建了一个 Observable 来访问远程服务器以获取一些数据。然而，由于服务器设计不善，可能永远没有响应，也没有例外。为了解决这个问题，我想要一些超时重试机制。

目前我尝试启动一个计时器来停止请求并在其中抛出异常，然后重试直到一定次数的尝试或我的真正超时。我尝试使用mergeWith运算符将请求与Observable.interval映射合并以使用生成错误Observable.error()，但是我无法在订阅者中捕获错误，并且看起来Observable.interval永无止境。

我应该如何处理 RXJAVA 中的任何操作员的这种情况？

我当前的代码如下所示：

Observable.fromEmitter(fetchNetwork->...)
.mergeWith(Observable.interval(...)
           .flatmap(n->(observable.error)))
.retryWhen(error->(checkTimeExceed))
.subscribe(handleResult)