使用Retrofit 2.0和RxJava获取响应状态代码

Question

Observable<MyResponseObject> apiCall(@Body body);

myRetrofitObject.apiCall(body).subscribe(new Subscriber<MyResponseObject>() {
        @Override
        public void onCompleted() {

        }

        @Override
        public void onError(Throwable e) {

        }

        @Override
        public void onNext(MyResponseObject myResponseObject) {
           //On response from server
        }
    });

在改版1.9中，RetrofitError仍然存在，我们可以通过以下操作获得状态：

error.getResponse().getStatus()

您如何使用RXJava在Registfit2.0中做到这一点？

Answer 1

而不是像您那样声明API调用：

Observable<MyResponseObject> apiCall(@Body body);

您也可以这样声明：

Observable<Response<MyResponseObject>> apiCall(@Body body);

然后，您将拥有如下所示的订阅服务器：

new Subscriber<Response<StartupResponse>>() {
    @Override
    public void onCompleted() {}

    @Override
    public void onError(Throwable e) {
        Timber.e(e, "onError: %", e.toString());

        // network errors, e. g. UnknownHostException, will end up here
    }

    @Override
    public void onNext(Response<StartupResponse> startupResponseResponse) {
        Timber.d("onNext: %s", startupResponseResponse.code());

        // HTTP errors, e. g. 404, will end up here!
    }
}

Observable<Response<MyResponseObject>> apiCall(@Body body);

甚至这个

Observable<Response<ResponseBody>> apiCall(@Body body);

所有响应都将在下一个中结束，而不管它们的错误代码是什么。这是可能的，因为所有内容都通过翻新包装在response对象中。

另一方面，如果调用是这样声明的：

Observable<MyResponseObject> apiCall(@Body body);

Observable<ResponseBody> apiCall(@Body body);