Advertisement
Guest User

Untitled

a guest
Mar 27th, 2017
42
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.65 KB | None | 0 0
  1. public Observable<String> getMyString(String key){
  2. WebRequestDbEntity myCachedString = mCache.getWebRequest(key);
  3. String cachedString = myCachedString.getValue();
  4.  
  5. return retrofitWebDataStore().getMyString(key)
  6. .startWith(Observable.just(cachedString))
  7. .map(networkString -> {
  8. mCache.saveRequest(key, networkString);
  9. return networkString;
  10. });
  11. }
  12.  
  13. getNeworkString(key)
  14. .subscribeOn(Schedulers.io())
  15. .observeOn(AndroidSchedulers.mainThread())
  16. .subscribe(this::onSuccess, this::onError);
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement