我已经按照以下方式设置了Retrofit和Rxjava。
Retrofit retrofit = ApiManager.getAdapter();
final SplashApiInterface splashApiInterface = retrofit.create(SplashApiInterface.class);
final Observable<List<Data>> observable = splashApiInterface.getTenData(offset);
observable.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).unsubscribeOn(Schedulers.io())
.subscribe(new Subscriber<List<Data>>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
e.printStackTrace();
}
@Override
public void onNext(List<Data> dataList) {
splashListener.takeDataToPres(dataList);
}
}
});
我的需求是这样的,API每次生成10个数据的列表,我需要通过增加偏移值来查询所有这些数据,然后将这些数据附加到列表中。如何在Android上使用RxJava实现这一点?
range
。Observable.range
只会发出偏移值。然后在下游,这个值被用来进行API调用。 - Maksim Ostrovidov