反覆做API調用與改造和rxjava

Question

我觀察到的一個改型：

@GET("something/") 
Observable<Something> getSomething(); 

訂閱它給人的響應。

getSomething().subscribe(new Subscriber<Something>() { 
      @Override 
      public void onCompleted() { 
      } 

      @Override 
      public void onError(Throwable e) { 
      } 

      @Override 
      public void onNext(Something something) { 
       //update database of something 
      } 
     }); 

我該如何每60秒進行一次這個調用，以便我可以相應地更新數據庫？

Answer 1

首先請不要這樣做，如果你能避免它。推薦更改（例如GCM）而不是拉動以節省電池和數據。

爲此，您可以使用Observable.interval和Observable.repeat運算符的組合。

Observable.interval(60, TimeUnit.SECONDS) 
    .flatMap(n -> getSomething()) 
    .repeat() 
    .subscribe(); 

抱歉有關lambda。