搜尋

首頁  >  問答  >  主體

android - rxjava多執行緒並發怎麼控制順序

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

怪我咯怪我咯2830 天前795

全部回覆(3)我來回復

  • ringa_lee

    ringa_lee2017-05-16 13:35:18

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

    回覆
    0
  • 给我你的怀抱

    给我你的怀抱2017-05-16 13:35:18

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

    回覆
    0
  • 过去多啦不再A梦

    过去多啦不再A梦2017-05-16 13:35:18

    雷雷

    回覆
    0
  • 取消回覆