引发异常.Add-onError处理

Question

我已经添加了onErrorReturn和doOnError，但仍然会出现致命错误。这是我的代码：

 apiInterface.submitDataToAnalyze("dataToAnalyze", HelperFunctions.authenticationData, 1, uuid, dataToAnalyze.toString(), todayDate)
                                .onErrorReturn(new Func1<Throwable, BasicResponse>() {
                                    @Override
                                    public BasicResponse call(Throwable throwable) {
                                        Log.e(FILE_NAME, "submitDataToAnalyze throwable??");
                                        Log.e(FILE_NAME, throwable.getMessage().toString());
                                        return null;
                                    }
                                })
                                .flatMap(new Func1<BasicResponse, Observable<LocationSuggestion>>() {
                                    @Override
                                    public Observable<LocationSuggestion> call(BasicResponse basicResponse) {
                                        Log.v(FILE_NAME, "basicResponse: " + basicResponse.toString());
                                        if (basicResponse.getResult() == 1) {
                                            //update TABLE_REQUEST_SUGGESTIONS with serverResponse = 1
                                            dbc.updateRequestSuggestionLog(strTodayDate, strDataToAnalyze, basicResponse.getResult());
                                            return apiInterface.getSuggestion("getSuggestion", HelperFunctions.authenticationData, HelperFunctions.requestVersion, uuid,
                                                    strLocationLat, strLocationLng, radius, requestForDate);
                                        } else {
                                            return Observable.just(null);
                                        }
                                    }
                                }).doOnError(new Action1<Throwable>() {
                            @Override
                            public void call(Throwable t) {
                                Log.e(FILE_NAME, "masuk doOnError??");
                                Log.e(FILE_NAME, t.getMessage().toString());
                            }

                        }).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe();
                }

具体来说，以下是错误消息：

E/ISRS: masuk doOnError??
E/ISRS: masuk 22??
E/AndroidRuntime: FATAL EXCEPTION: main
java.lang.IllegalStateException: Exception thrown on Scheduler.Worker thread. Add `onError` handling.
at rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:60)

附加信息：如果submitDataToAnalyze（）由于连接不好等原因而无法连接到我的服务器，则会发生致命错误。

Answer 1

在onErrorReturn方法中，您返回null，然后该null将沿链进一步传播。因此它导致了NPE（如basicResponse.toString()）。在这种情况下，调用了doOnError，但您的订阅者仍然获得了Throwable，这仍然是未处理的。

因此，您必须使用onError实现传递Subscriber实例。

另一种选择是：在你的链中，你可以使用类似onErrorResumeNext(Observable.empty())的东西，这样它就不会发出任何东西，然后就完成了。在这种情况下，您不必将Subscriber实现传递给subscribe。