繰り返し私が観察改造を持って改造し、rxjava

Question

とAPI呼び出しを行います。それに加入

@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(); 

大変申し訳ございません。