这是我想要实现的目标:
我有一个API响应说myResponse
,其中包含项目的List
。我想通过flatMapIterable
遍历每个项目,效果很好。但是在此之前,我想检查API是否未返回错误或List
大小是否大于0。我无法实现此目的。
这是到目前为止我尝试过的代码:
// This works & I am able to iterate through each item
myApi.getData()
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.flatMapIterable(response -> response.getData().getItems())
.subscribeWith(new DisposableObserver<Mobile>() {
@Override
public void onNext(@NonNull Item item) {
Log.e("TAG", "item is => " + item.getItemName());
}
@Override
public void onError(@NonNull Throwable e) {
}
@Override
public void onComplete() {
Log.e("TAG", "processing completed");
}
});
但是我不确定在
map
之前应该如何使用flatmap
或flatMapIterable
来检查任何错误。我正在做类似的事情,但没有成功:myApi.getData()
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.map(response -> {
if(response.getStatus() == 200) {
List<Item> items = response.getData().getItems();
if(items == null || items.size() < 1)
return Observable.error(new Throwable("No data!"));
return Observable.just(response);
}
return Observable.error(new Throwable(response.getData().getMsg()));
})
.doOnError(Throwable::getMessage)
.flatMapIterable(response -> response.getData().getItems());
在
flatMapIterable
上,出现错误无法解析getData()。因为我相信它无法将response
标识为MyResponse.class
。我被困在这里,请让我知道如何使用RxJava2实现我想要的? 最佳答案
在map(response -> {...})
中创建了Observable
的MyResponse
,这就是为什么它不编译的原因。只需将map(response -> {...})
替换为flatMap(response -> {...})
或在flatMap(r -> r)
之前添加flatMapIterable
。