如何添加超时以检测可观察对象有一段时间没有发出

Question

我的用例如下：

我创建了一个可观察的来访问远程服务器以获取一些数据。但是，由于服务器设计不完善，因此可能永远没有响应，也没有异常。为了解决这个问题，我希望有一些超时重试机制。

目前，我尝试启动一个计时器来停止请求，并在请求中抛出异常，然后重试，直到达到一定的尝试次数或实际超时。我试着使用mergeWith操作符将请求与可观察项合并。间隔映射为使用可观察值生成错误。error（），但是我无法在订阅服务器中捕获错误，它看起来像是可以观察到的。间隔永远不会结束。

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

我当前的代码如下所示：

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

Answer 1

您可以将timeout（）运算符与retryWhen（）一起使用：

Observable.fromEmitter(fetchNetwork->...)
     .timeout(TIMEOUT_VALUE, TimeUnit.SECONDS)
     .retryWhen(observable -> observable.flatMap(error -> {
                if (error instanceof TimeoutException) {
                    return Observable.just(new Object());
                } else {
                    return Observable.error(error);
                }
            }))
     .subscribe(handleResult)

这将在超时值秒后使请求超时，并在请求超时时重试，其他错误将像往常一样传播到订阅服务器onError（）。