使用RxJava处理分页

您可以递归建模：

Observable<ApiResponse> getPageAndNext(int page) {  return getResults(page)      .concatMap(new Func1<ApiResponse, Observable<ApiResponse>>() {        @Override        public Observable<ApiResponse> call(ApiResponse response) {          // Terminal case.          if (response.next == null) { return Observable.just(response);          }          return Observable.just(response)   .concatWith(getPageAndNext(response.next));        }      });}

然后，要消耗它，

getPageAndNext(0)    .concatMap(new Func1<ApiResponse, Observable<ResponseObject>>() {        @Override        public Observable<ResponseObject> call(ApiResponse response) {          return Observable.from(response.results);        }    })    .subscribe(new Action1<ResponseObject>() {  });

那应该使您有一个流ResponseObject将按顺序到达，并且很可能以页面大小的块到达。