RxJava Android onError 调用时间过长

Question

我在我的 Android 应用上使用 RxJava，但 onError 有问题。

我正在这样做：

operationalLayer.operationalConfig(new OperationalRequest())
    .subscribeOn(Schedulers.immediate())
    .observeOn(Schedulers.immediate())
    .subscribe(new CustomSubscriber<OperationalResponse>(bundle, null) {
        @Override
        public void onNext(OperationalResponse response) {
          //Do something
            super.onNext(response);
        }
    });

在某些时候，在operationalConfig 方法中，我检查网络连接是否可用，如果不可用，则返回错误。

public Observable<OperationalResponse> operationalConfig(final OperationalRequest operationalRequest) {
    if (!Network.hasInternet()) {
        Log.d("No available internet for operationalConfig");
        return Observable.error(new NoInternetException());
    }

    return Observable.defer....
}

比，在我的CustomSubscriber 我有这个：

@Override
public void onError(final Throwable e) {
    if (e instanceof NoInternetException) {
        // do something
        Log.d("No internet connection available");
    } 
    // other things
}

查看日志消息我有一个巨大的延迟，因为它检测到没有可用的互联网连接并且调用了onError 方法。

11-16 12:07:37.378 23779-24183 D/CustomTag: OperationalLayer No available internet for operationalConfig
11-16 12:07:57.459 23779-24416 D/CustomTag: CustomSubscriber No internet connection available

知道为什么吗？

Answer 1

找到问题了。

没有在此处发布代码，因为认为它不相关。事实上确实如此。

在operationalLayer.operationalConfig 和方法本身之间我有这个：

@Override
    public Observable<OerationalResponse> operationalConfig(OperationRequest operationalRequest) {
        //Something
        return network.opcoConfigs(opcoConfigRequest)
                .retryWhen(//Something);
    }

在我传递给retryWhen 的Func 中，我现在正确处理错误，以便在没有网络连接时立即停止重试机制并将InternetException 返回给订阅者。