多个顺序观察与及时之间的延迟每个人之间

我想要得到google places和每个API限制你不能得到超过20个地方每个请求，下一个请求需要nextPageToken以前的请求。多个顺序观察与及时之间的延迟每个人之间

问题：

Zip运营商立即执行所有要求，但我需要他们的Observable呼叫
Delay操作4 seconds之间的每个
允许等待连续的，及时的延迟，但它到底是什么，它立即执行Zip来电和未期望在延迟一定时间后返回我的结果。

我的资料来源：

LatLng some = new LatLng(31.471199, 74.234940); 
Observable 
     .zip(getNearByPlaces(some), getNearByPlaces(some), getNearByPlaces(some), new Func3<List<PlaceInfo>, List<PlaceInfo>, List<PlaceInfo>, List<PlaceInfo>>() { 
      @Override 
      public List<PlaceInfo> call(List<PlaceInfo> placeInfos, List<PlaceInfo> placeInfos2, List<PlaceInfo> placeInfos3) { 
       placeInfos2.addAll(placeInfos3); 
       placeInfos.addAll(placeInfos2); 
       return placeInfos; 
      } 
     }) 
     .subscribeOn(Schedulers.io()) 
     .observeOn(AndroidSchedulers.mainThread()) 
     .subscribe(new Observer<List<PlaceInfo>>() { 
      @Override 
      public void onCompleted() { 
      } 

      @Override 
      public void onError(Throwable e) { 
       e.printStackTrace(); 
      } 

      @Override 
      public void onNext(List<PlaceInfo> placeInfos) { 
       adapter.setPlaces(placeInfos); 
      } 
     });

我是初学者，使用rxjava约1星期前开始，所以你可以期待的错误。

来源

2016-11-12 Zulqurnain Jutt

你好?????????? –

让我们假设你有以下响应模型

class Response { 
    private String pageToken; 
    private List<PlaceInfo> places; 

    //setters, getters etc 
}

而且有两个方法：用API

Observable<Response> getNearByPlaces(LatLng latLng) {...} 
Observable<Response> getNextNearByPlaces(String pageToken) {...}

工作定义Transformer获取额外的地方。它等待4秒钟，然后获取下一个地方并添加源地点到响应中。

private Observable.Transformer<Response, Response> addNextPlaces() { 
    return observable -> observable 
      .delay(4, TimeUnit.SECONDS) 
      .flatMap(sourceResponse -> getNextNearByPlaces(sourceResponse.getPageToken()), 
        ((sourceResponse, nextResponse) -> { 
         nextResponse.getPlaces().addAll(sourceResponse.getPlaces()); 
         return responseNext; 
        })); 
}

然后，你可以做什么，你需要这样

getNearByPlaces(latLng) 
     .compose(addNextPlaces()) 
     //add here additional compose methods if you need them 
     .subscribe(resultResponse -> { 
      resultResponse.getPlaces() //handle result List 
     }, error -> { 
      //handle error 
     });

附：了解线程。 delay切换计划程序来computation

P.P.S.我怀疑还有一种更简单和优雅的解决方案:)

来源

2016-11-12 09:22:21

谢谢，它的工作，只是最后一个问题是，它的三个请求过程，但上面的示例处理2请求我想 –

'.compose（addNextPlaces（））'添加一个额外的请求，所以如果你想链更多的请求 - 只需复制粘贴该字符串并将其放置在下面 –

多个顺序观察与及时之间的延迟每个人之间

回答

相关问题