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

Question

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

Answer 1

フィルタリングしたい場合は、Filter 演算子を使用する必要があります

Answer 2

この演算子 concatMap を使用すると、スレッドの実行順序が乱れることがなくなります。

Answer 3

リーリー