RxJava: Сеть и кеш испускают частичные результаты

Question

У меня есть простой случай для решения, но я еще не нашел, как реализовать его с RxJava. С одной стороны у меня есть Retrofit (сеть), а с другой стороны - база данных SQLite (кеш).

То, что я хотел бы достичь, это:

• Если нет ничего в кэше: вызов API-интерфейс
• Если есть что-то в кэше:
  • , если набор данных до -to-date: испускать только результаты из db
  • , если набор данных устарел: испустить устаревшие результаты, а затем вызвать API (и испустить результаты)

Вы знаете, как реализовать это поведение с помощью Rxjava (версия 1)?

Большое спасибо!

Answer 1

В этом случае уже много статей. Для того, чтобы назвать несколько:

• Loading data from multiple sources with RxJava - Dan Lew

• Pseudo caching : retrieve data first from a cache, then a network call (using concat, concatEager, merge or publish) - Kaushik Gopal

• Chaining multiple sources with RxJava - Miguel Juárez

Answer 2

Что-то, как это должно работать:

Observable<Foo> cache = getCacheFoo(); 
    Observable<Foo> network = getNetworkFoo(); 

    Observable<Foo> foos = cache.flatMap(cachedFoo -> { 
     if (cachedFoo == null) { 
      // if the cache returns nothing, return the network observable 
      return network; 
     } else if (cachedFoo.isStale()) { 
      // if the cache is stale, return the data, but follow up with the network 
      return Observable.just(cachedFoo).concatWith(network); 
     } else { 
      // otherwise the data is fresh, simply return it 
      return Observable.just(cachedFoo); 
     } 
    });