Question

android 用rxjava和retrofit时怎么解决返回数据类型不一致

Answer 1

1. 首先定义带泛型的返回结果，Retrofit API 的原生结果映射为这种形式：
class Result<T> {
String ResultMessage;
int ResultCode;
T Data;
}

2. 处理错误的方法和 @朱诗雄 前辈方法差不多，放到作为静态方法放到 RetroUtil 里，这里 ApiException 为自己定义的一个异常，放入错误码和错误信息（错误码不止一个）：

static <T> Observable<T> flatResult(Result<T> result) {
return Observable.create(subscriber -> {
switch (result.ResultCode) {
case Constants.SUCCESS_CODE:
subscriber.onNext(result.Data);
break;
case Constants.ERROR_CODE:
subscriber.onError(new ApiException(result.ResultCode, result.ResultMessage);
break;
default:
// ...
}
subscriber.onCompleted();
}
});
}

3. 在 API 包装类对于上述 Result<T> 格式的返回结果，统一调用 flatMap(RetroUtil::flatResult) 后的 API。这样每个 API 的返回结果就是 Observable<Data> 的形式并且在 errorHandler 中统一处理错误了。

// 接口方法
Observable<Result<User>> getUserInfo();

// 包装后的方法
Observable<User> getUserInfo() {
return mApi.getUserInfo.flatMap(RetroUtil::flatResult);
}

// 调用时
apiWrapper.getUserInfo()
.subscrible(user -> {
// 处理正常逻辑
}, error -> {
// 处理错误逻辑和异常，这里封装时通常也会统一处理，
// 提供一个默认的 Action1<Throwable> 参数，弹出
// throwable 的 message 打印日志等
});