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