android - rxjava 條件判斷
問題描述
我想實(shí)現(xiàn)這樣一個(gè)功能,用戶點(diǎn)擊獲取數(shù)據(jù)庫(kù)數(shù)據(jù),若數(shù)據(jù)庫(kù)有這個(gè)數(shù)據(jù),則直接顯示本地的,若數(shù)據(jù)庫(kù)沒有這個(gè)數(shù)據(jù),就從服務(wù)器請(qǐng)求再顯示出來。請(qǐng)問一下用rxjava要怎么寫呢?
問題解答
回答1:1.先把功能函數(shù)寫出來.
private static Object loadFromCache(String key) { //....本地緩存加載,如果加載失敗返回 null } private static Object loadFromServer(String key) { //....通過網(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),);
相關(guān)文章:
1. mac里的docker如何命令行開啟呢?2. 關(guān)于docker下的nginx壓力測(cè)試3. docker - 各位電腦上有多少個(gè)容器啊?容器一多,自己都搞混了,咋辦呢?4. nignx - docker內(nèi)nginx 80端口被占用5. 關(guān)docker hub上有些鏡像的tag被標(biāo)記““This image has vulnerabilities””6. docker容器呢SSH為什么連不通呢?7. Docker for Mac 創(chuàng)建的dnsmasq容器連不上/不工作的問題8. docker 下面創(chuàng)建的IMAGE 他們的 ID 一樣?這個(gè)是怎么回事????9. angular.js使用$resource服務(wù)把數(shù)據(jù)存入mongodb的問題。10. docker-compose 為何找不到配置文件?

網(wǎng)公網(wǎng)安備