如何使用 Retrofit 2 和 RxJava 处理分页

Posted 2023-03-22

【中文标题】如何使用 Retrofit 2 和 RxJava 处理分页

【英文标题】：How to handle pagination with Retrofit 2 and RxJava

【发布时间】：2016-08-29 17:29:00

【问题描述】：

我知道如何处理 Retrofit 响应，但在使用 rx java 从 REST API 处理分页时遇到问题。

背景

我正在使用的其余 api 为我提供以下响应，并在标题中包含指向下一页的链接：

HTTP 200 OK
Allow: GET, HEAD, OPTIONS
Content-Type: application/json
Link: <http://some-endpoint.com/pictures?page=2>; rel="next"
Vary: Accept
X-Total-Count: 80

[
    
        "id": 3,
        "url": "",
        "picture": 
            "id": 6,
            "url": "",
            "name": "Chrysler"
        ,
        "location": 
            "type": "Point",
            "coordinates": [
                10.108956,
                41.389576000000005
            ]
        
    ,
    
        "id": 4,
        "url": "",
        "picture": 
            "id": 26,
            "url": "",
            "name": "Douglas Aircraft"
        ,
        "location": 
            "type": "Point",
            "coordinates": [
                10.1977759999999997,
                41.426645
            ]
        
    ,
...

知道我设法使用以下代码将分页请求转到第 2 页，但我不知道如何发出这些分页请求，直到响应中没有“下一个”标头链接，所以我可以保存从所有请求到数据库的所有数据。

private Observable<List<PictureEntity>> getPictures(final LocationEntity locationEntity) 
    if (getDataFromServer()) 
        return mApiService.getPictures()
                .concatMap(new Func1<Response<List<Picture>>, Observable<Response<List<Picture>>>>() 
                    @Override
                    public Observable<Response<List<Picture>>> call(Response<List<Picture>> listResponse) 
                        String link = NetworkUtil.getNextLinkPaginate(listResponse.headers().get("Link"));
                        Timber.i(link);
                        return Observable.just(listResponse)
                                .concatWith(mApiService.getPicturesPaginate(link))
                                .reduce(new Func2<Response<List<Picture>>, Response<List<Picture>>,
                                        Response<List<Picture>>>() 
                                    @Override
                                    public Response<List<Picture>> call(Response<List<Picture>> listResponse,
                                                                            Response<List<Picture>> listResponse2) 
                                        listResponse.body().addAll(listResponse2.body());
                                        return listResponse;
                                    
                                );
                    
                )
                .concatMap(new Func1<Response<List<Picture>>, Observable<List<PictureEntity>>>() 
                    @Override
                    public Observable<List<PictureEntity>> call(Response<List<Picture>> listResponse) 
                        List<PictureEntity> pictureEntities =
                                mPictureDataMapper.transformToEntity(listResponse.body());
                        mDatabaseHelper.setPictureEntity(pictureEntities).subscribe();
                        return mDatabaseHelper.getNearbyPicturesEntity(locationEntity);
                    
                );
     else 
        return mDatabaseHelper.getNearbyPicturesEntity(locationEntity);
    

关于如何处理此类请求的任何建议？也许 .takeUntil 运算符？

【问题讨论】：

Paginate Observable results without recursion - RxJava的可能重复

我不认为这可能是重复的@AdamMillerchip，因为这个问题比你建议的要早。

年龄是否相关？他们正在讨论同一个问题，而对另一个问题的答复更有用，这就是为什么我将这个问题标记为重复。实际上有四五个类似的问题，所以我只选择了最常见的一个。

【参考方案1】：

您可以使用带有一点递归的 concatMap。

Observable<List<PointOfSaleEntity>> getPointsOfSalePaginateUntilEnd(String link) 
  if (link.equals("")) 
      return Observable.empty();
   else       
      return mApiService.getPointsOfSalesPaginate(link)                     
                        .concatMap(listResponse -> Observable.concat(Observable.just(listResponse),mApiService.getPointsOfSalesPaginate(NetworkUtil.getNextLinkPaginate(listResponse.headers().get("Link")))));
  


Observable<List<PointOfSaleEntity>> getPointsOfSalePaginateUntilEnd()    
       return mApiService.mApiService.getPointsOfSales()                        
                         .concatMap(listResponse -> Observable.concat(Observable.just(listResponse),mApiService.getPointsOfSalesPaginate(NetworkUtil.getNextLinkPaginate(listResponse.headers().get("Link")))));