我有按页面返回数据的API,如下所示:
{
"count": 100,
"offset": 0,
"limit": 25,
"result": [{}, {}, {}...]
}
我需要获取所有页面-所有数据(以不同的“偏移量”执行查询:)。
Observable<MyResponse> call = RetrofitProvider.get().create(MyApi.class).getData(0, 25); // limit and offset
call.observeOn(AndroidSchedulers.mainThread())
.subscribeOn(Schedulers.newThread())
.doOnNext(<saving data>)
.subscribe(result -> {
}, error -> {
});
我正在尝试使用RxAndroid和Retrofit。最好的方法是什么?
最佳答案
您可以将发布主题用作可观察的源,然后继续为下一个范围动态添加新请求。
private Observable<ApiResponse> getData(int start, int end) {
// Get your API response value
return RetrofitProvider.get().create(MyApi.class).getData(0, 25);
}
public Observable<ApiResponse> getAllData() {
final PublishSubject<ApiResponse> subject = PublishSubject.create();
return subject.doOnSubscribe(new Action0() {
@Override
public void call() {
getData(0, SECTION_SIZE).subscribe(subject);
}
}).doOnNext(new Action1<ApiResponse>() {
@Override
public void call(ApiResponse apiResponse) {
if (apiResponse.isFinalResultSet()) {
subject.onCompleted();
} else {
int nextStartValue = apiResponse.getFinalValue() + 1;
getData(nextStartValue, nextStartValue + SECTION_SIZE).subscribe(subject);
}
}
});
}