問題描述

我想實現這樣一個功能，用戶點擊獲取數據庫數據，若數據庫有這個數據，則直接顯示本地的，若數據庫沒有這個數據，就從服務器請求再顯示出來。請問一下用rxjava要怎么寫呢？

問題解答

1.先把功能函數寫出來.

private static Object loadFromCache(String key) { //....本地緩存加載，如果加載失敗返回 null } private static Object loadFromServer(String key) { //....通過網絡加載，返回數據 Object obj = .... saveToCache(key, obj);//保存到本地緩存 return obj; }

2.將阻塞方法轉為RxJava的寫法

private static Observable<Object> rxLoadFromCache(String key) {return Observable.fromCallable(() -> loadFromCache(key)); } private static Observable<Object> rxLoadFromServer(String key) {return Observable.fromCallable(() -> loadFromServer(key)); }

3.合并到一起

public static Observable<Object> rxLoad(String key) {return Observable.concat(rxLoadFromCache(key),rxLoadFromServer(key)).filter(obj -> obj != null) .take(1); }

4.調用最后的方法

rxLoad(key) .subscribeOn(Schedulers.io()) .subscribe(obj->{ System.out.println(obj); });回答2：

Observable.concat(Observable.just(null), Observable.just(1)).filter(integer -> integer != null).take(1).subscribe(integer -> { //TODO});回答3：

Observable.if( () -> { return hasCache; }, Observable.just(cache), Observable.just(database),);