検索

ホームページ  >  に質問  >  本文

android - rxjava マルチスレッド同時実行の順序を制御する方法

要件は、サーバーからチャット リストを取得し、トラバースしてチャット レコードを取得することです。ここでは Observable.from(conversations) を使用し、会話をローカル データベースに挿入し、フィルタリングして必要なデータを取得します。ビューを更新しました
午後ずっと見ていたので、複数のキーワードに関連しています
SerializedSubject (SerializedSubject.from(conversations) は使用できず、Observable に変換するときにエラーが報告されます)
トランポリン (タスクをキューに入れます)現在のスレッド、現在のタスクが完了するまで待機し、キューの実行を続行します) タスク)
concatEager (この演算子と concatMap http://blog.csdn.net/kisty_ya... の違いは何ですか...は使用例がなく理解できません)
最初はonNextで次のステップを処理し、次に flatMap で処理しましたが、onNext を待たずに起動が完了した時点で終了しました。 doOnNext と flatMap は同じだと思います。アイデアを疑似コードに書き留めていただけますか。

怪我咯怪我咯2794日前773

全員に返信(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
  • キャンセル返事