我目前正试图绕过RxJava，但我在处理服务调用异常方面遇到了一些麻烦。
基本上，我有一个（Retrofit）服务返回一个 Observable<ServiceResponse>。 ServiceResponse 定义如下：
public class ServiceResponse {
private int status;
private String message;
private JsonElement data;
public JsonElement getData() {
return data;
}
public int getStatus() {
return status;
}
public String getMessage() {
return message;
}
}
现在我想要的是将该通用响应映射到a List<Account> 包含在数据JsonElement字段中（我假设你不在乎什么 Account 对象看起来像，所以我不会用它污染帖子）。以下代码适用于成功案例，但我找不到处理API异常的好方法：
service.getAccounts()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.map(new Func1<ServiceResponse, AccountData>() {
@Override
public AccountData call(ServiceResponse serviceResponse) {
// TODO: ick. fix this. there must be a better way...
ResponseTypes responseType = ResponseTypes.from(serviceResponse.getStatus());
switch (responseType) {
case SUCCESS:
Gson gson = new GsonBuilder().create();
return gson.fromJson(serviceResponse.getData(), AccountData.class);
case HOST_UNAVAILABLE:
throw new HostUnavailableException(serviceResponse.getMessage());
case SUSPENDED_USER:
throw new SuspendedUserException(serviceResponse.getMessage());
case SYSTEM_ERROR:
case UNKNOWN:
default:
throw new SystemErrorException(serviceResponse.getMessage());
}
}
})
.map(new Func1<AccountData, List<Account>>() {
@Override
public List<Account> call(AccountData accountData) {
Gson gson = new GsonBuilder().create();
List<Account> res = new ArrayList<Account>();
for (JsonElement account : accountData.getAccounts()) {
res.add(gson.fromJson(account, Account.class));
}
return res;
}
})
.subscribe(accountsRequest);
有一个更好的方法吗？这个 不 工作，onError会激发给我的观察者，我会收到我扔的错误，但看起来我似乎并没有这样做。
提前致谢！
编辑：
让我澄清一下我想要实现的目标：
我希望有一个可以从UI调用的类（例如，Activity或Fragment，或其他）。该课程需要一个 Observer<List<Account>> 像这样的参数：
public Subscription loadAccounts(Observer<List<Account>> observer, boolean forceRefresh) {
...
}
当UI被分离/销毁/等时，该方法将返回可以取消订阅的订阅。
参数化观察者将处理onNext，以便在Accounts列表中传递成功的响应。 OnError会处理任何异常，但也会传递任何API异常（例如，如果响应状态！= 200，我们将创建一个Throwable并将其传递给onError）。理想情况下，我不想只是“抛出”异常，我想将它直接传递给Observer。这就是我看到的所有例子。
复杂的是我的Retrofit服务返回了一个 ServiceResponse 对象，所以我的观察者不能订阅它。我提出的最好的方法是在Observer周围创建一个Observer包装器，如下所示：
@Singleton
public class AccountsDatabase {
private AccountsService service;
private List<Account> accountsCache = null;
private PublishSubject<ServiceResponse> accountsRequest = null;
@Inject
public AccountsDatabase(AccountsService service) {
this.service = service;
}
public Subscription loadAccounts(Observer<List<Account>> observer, boolean forceRefresh) {
ObserverWrapper observerWrapper = new ObserverWrapper(observer);
if (accountsCache != null) {
// We have a cached value. Emit it immediately.
observer.onNext(accountsCache);
}
if (accountsRequest != null) {
// There's an in-flight network request for this section already. Join it.
return accountsRequest.subscribe(observerWrapper);
}
if (accountsCache != null && !forceRefresh) {
// We had a cached value and don't want to force a refresh on the data. Just
// return an empty subscription
observer.onCompleted();
return Subscriptions.empty();
}
accountsRequest = PublishSubject.create();
accountsRequest.subscribe(new ObserverWrapper(new EndObserver<List<Account>>() {
@Override
public void onNext(List<Account> accounts) {
accountsCache = accounts;
}
@Override
public void onEnd() {
accountsRequest = null;
}
}));
Subscription subscription = accountsRequest.subscribe(observerWrapper);
service.getAccounts()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(accountsRequest);
return subscription;
}
static class ObserverWrapper implements Observer<ServiceResponse> {
private Observer<List<Account>> observer;
public ObserverWrapper(Observer<List<Account>> observer) {
this.observer = observer;
}
@Override
public void onCompleted() {
observer.onCompleted();
}
@Override
public void onError(Throwable e) {
observer.onError(e);
}
@Override
public void onNext(ServiceResponse serviceResponse) {
ResponseTypes responseType = ResponseTypes.from(serviceResponse.getStatus());
switch (responseType) {
case SUCCESS:
Gson gson = new GsonBuilder().create();
AccountData accountData = gson.fromJson(serviceResponse.getData(), AccountData.class);
List<Account> res = new ArrayList<>();
for (JsonElement account : accountData.getAccounts()) {
res.add(gson.fromJson(account, Account.class));
}
observer.onNext(res);
observer.onCompleted();
break;
default:
observer.onError(new ApiException(serviceResponse.getMessage(), responseType));
break;
}
}
}
}
我仍然觉得我没有正确使用这个。我以前没有见过其他人使用ObserverWrapper。也许我不应该使用RxJava，尽管SoundCloud和Netflix的人员在他们的演示文稿中真的把它卖给了我，我非常渴望学习它。