地图中的改造 + rx 错误处理

Question

如果响应不成功，我想处理我的地图中的错误。我已尝试使用本文Error handling in Retrofit 中的 RetrofitException，但未成功。

这是我的 Observable

    public Observable<JsonElement> commonResponse(final Object request, String method, final Context context) {

    Log.v("method", method);
    //Create Request
    Map<String, Object> data = ApiHelper.commonParams(request, method, context);

    return apiService.commonResponse(method, data)
            .subscribeOn(Schedulers.newThread())
            .observeOn(Schedulers.immediate())
            .map(new Func1<Response<BaseResponse>, JsonElement>() {
                @Override
                public JsonElement call(Response<BaseResponse> response) {
                    if (!response.isSuccessful()) {
                        //throwException(response);                            

                    }

                    BaseResponse baseResponse = response.body();
                    return baseResponse.getData();
                }
            });

}

这是我的改造

    private static HttpLoggingInterceptor logging = new HttpLoggingInterceptor();

private static OkHttpClient.Builder httpClient = new OkHttpClient.Builder();

private static Retrofit.Builder builder =
        new Retrofit.Builder()
                .baseUrl(ApiService.API_URL)
                .addConverterFactory(GsonConverterFactory.create())
                .addCallAdapterFactory(RxJavaCallAdapterFactory.create());

public static Retrofit retrofit = builder.client(httpClient.addInterceptor(logging.setLevel(HttpLoggingInterceptor.Level.BASIC)).build()).build();

public static ApiService retrofitCreate() {
    return retrofit.create(ApiService.class);
}

Answer 1

添加 subscribe 给你 Observerable 我认为可以解决你的问题。最后你方法添加 subscribe:

              .subscribe(new Subscriber<YOUR_OBJECT>() {
                    @Override
                    public void onCompleted() {

                    }

                    @Override
                    public void onError(Throwable e) {
                        //handle your error here
                        showError();
                    }

                    @Override
                    public void onNext(YOUR_OBJECT object) {
                    }

查看更多here。