android - rxjava多執行緒並發怎麼控制順序
怪我咯
怪我咯 2017-05-16 13:33:18
0
3
726

需求是從伺服器取得聊天列表,然後遍歷取得聊天記錄,我這裡用了Observable.from(conversations)然後對conversation插入本地資料庫,並且過濾得到需要的數據,最後更新view
我看了一下午,這麼多關鍵字相關
SerializedSubject(我用SerializedSubject.from(conversations)也不行,而轉類型Observable也報錯)
trampoline(把任務放到當前線程的隊列中,等當前任務執行完了,再繼續執行佇列中的任務)
concatEager(這個操作符跟concatMap有什麼差別http://blog.csdn.net/kisty_ya... 但是使用上沒例子不太懂)
剛開始是onNext裡面處理下一步驟,然後我就用flatMap處理了,但是還是發射完成就結束了,沒有等onNext執行完,而且感覺doOnNext和flatMap是一樣的,希望能夠指點迷津,感覺像無頭蒼蠅一樣,能不能用偽代碼寫一下思路謝謝

怪我咯
怪我咯

走同样的路,发现不同的人生

全部回覆(3)
左手右手慢动作

過濾的話應該用Filter這個運算子吧

给我你的怀抱

用這個操作符concatMap可以確保執行緒執行的順序不會錯亂!

熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板
關於我們 免責聲明 Sitemap
PHP中文網:公益線上PHP培訓,幫助PHP學習者快速成長!