Многократно сделать вызов 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(); 

Извините за лямбды.