android - 使用 rxjava 正确处理所有类型的改造错误

Question

我是新手Rxjava，Retrofit我正在寻求最好的正确方法来处理改造中所有可能的状态rxjava，rxbinding其中包括：

1. 没有网络连接。
2. 来自服务器的空响应。
3. 成功响应。
4. 错误响应并显示错误消息，如Username or password is incorrect.
5. 其他错误如connection reset by peers.

Answer 1

对于每个重要的失败响应，我都有异常子类。异常作为 传递Observable.error()，而值通过流传递而没有任何包装。

1）没有互联网 - ConnectionException

2) Null - 只是 NullPointerException

4) 检查“错误请求”并抛出 IncorrectLoginPasswordException

5) 任何其他错误只是 NetworkException

onErrorResumeNext()您可以使用和映射错误map()

例如

从 Web 服务获取数据的典型改造方法：

public Observable<List<Bill>> getBills() {
    return mainWebService.getBills()
            .doOnNext(this::assertIsResponseSuccessful)
            .onErrorResumeNext(transformIOExceptionIntoConnectionException());
}

确保响应正常的方法，否则抛出适当的异常

private void assertIsResponseSuccessful(Response response) {
    if (!response.isSuccessful() || response.body() == null) {
        int code = response.code();
        switch (code) {
            case 403:
                throw new ForbiddenException();
            case 500:
            case 502:
                throw new InternalServerError();
            default:
                throw new NetworkException(response.message(), response.code());
        }

    }
}

IOException 表示没有网络连接，所以我抛出 ConnectionException

private <T> Function<Throwable, Observable<T>> transformIOExceptionIntoConnectionException() {
    // if error is IOException then transform it into ConnectionException
    return t -> t instanceof IOException ? Observable.error(new ConnectionException(t.getMessage())) : Observable.error(
            t);
}

为您的登录请求创建新方法，该方法将检查登录名/密码是否正常。

最后还有

subscribe(okResponse -> {}, error -> {
// handle error
});