問(wèn)題描述

需求是從服務(wù)器獲取聊天列表，然后遍歷獲取聊天記錄，我這里用了Observable.from(conversations)然后對(duì)conversation插入本地?cái)?shù)據(jù)庫(kù),并且過(guò)濾得到需要的數(shù)據(jù)，最后更新view我看了一下午，這么多關(guān)鍵詞相關(guān)SerializedSubject(我用SerializedSubject.from(conversations)也不行，而轉(zhuǎn)類型Observable也報(bào)錯(cuò))trampoline（把任務(wù)放到當(dāng)前線程的隊(duì)列中，等當(dāng)前任務(wù)執(zhí)行完了，再繼續(xù)執(zhí)行隊(duì)列中的任務(wù)）concatEager(這個(gè)操作符跟concatMap有什么區(qū)別http://blog.csdn.net/kisty_ya... 但是使用上沒(méi)例子不太懂)剛開始是onNext里面處理下一步驟，然后我就用flatMap處理了，但是還是發(fā)射完成就結(jié)束了，沒(méi)有等onNext執(zhí)行完，而且感覺(jué)doOnNext和flatMap是一樣的，希望能夠指點(diǎn)迷津，感覺(jué)像無(wú)頭蒼蠅一樣，能不能用偽代碼寫一下思路謝謝

問(wèn)題解答

過(guò)濾的話應(yīng)該用Filter這個(gè)操作符吧

用這個(gè)操作符concatMap可以保證線程執(zhí)行的順序不會(huì)錯(cuò)亂！

Obserable.fromCallable() .filter() .subscribe(io) .obserableOn(ui) .subscribe(action) 如果是需要將過(guò)濾的數(shù)據(jù)重新保存 Obserable data = Obserable.fromCallable() .filter() .subscribe(io) .share(); data.obserableon(io) .subscribe(數(shù)據(jù)庫(kù)) data.obserableOn(ui) .subscribe(更新)