問(wèn)題描述

我想實(shí)現(xiàn)這樣一個(gè)功能，用戶點(diǎn)擊獲取數(shù)據(jù)庫(kù)數(shù)據(jù)，若數(shù)據(jù)庫(kù)有這個(gè)數(shù)據(jù)，則直接顯示本地的，若數(shù)據(jù)庫(kù)沒(méi)有這個(gè)數(shù)據(jù)，就從服務(wù)器請(qǐng)求再顯示出來(lái)。請(qǐng)問(wèn)一下用rxjava要怎么寫呢？

問(wèn)題解答

1.先把功能函數(shù)寫出來(lái).

private static Object loadFromCache(String key) { //....本地緩存加載，如果加載失敗返回 null } private static Object loadFromServer(String key) { //....通過(guò)網(wǎng)絡(luò)加載，返回?cái)?shù)據(jù) Object obj = .... saveToCache(key, obj);//保存到本地緩存 return obj; }

2.將阻塞方法轉(zhuǎn)為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.調(diào)用最后的方法

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),);