rxJava, Actualiser les données api périodiquement

Question

J'utilise l'observable suivant pour appeler api de retrofit puis enregistrez la réponse dans le fichier de cache:

@Override public Observable<StoryCollectionEntity> storyEntityList(final int page) { 

     return this.restApi.storyCollection(id, page) 
     .doOnNext(saveStoryCollectionToCacheAction)   
    .onErrorResumeNext(CloudNewsDataStore.this.mNewsCache.getStories(page)); 
      } 

Cela fonctionne comme prévu. Ma question est la suivante: comment puis-je faire que cet observateur retourne réponse api périodiquement?

disons, l'utilisateur veut actualiser les données toutes les 5 minutes

Answer 1

L'opérateur interval() émettra un élément à un intervalle de temps donné.

Vous pouvez l'utiliser pour déclencher des événements périodiques comme ceci:

Observable.interval(5, TimeUnit.MINUTES) 
      .flatMap(count -> this.restApi.storeCollection(id, page)) 
      // etc.