問題タブ [rx-java]

rxjava-android が別のスレッドで操作を実行し (正しいスケジューラが提供されている場合)、ノンブロッキング操作につながることは私の理解でしたが、迅速で汚いテストはこれが正しくないことを証明しているようです。

次のコード スニペットを使用しましたが、両方のシナリオで UI がブロックされていました...

スニペット 1

スニペット 2

ここで何か不足していますか？

カスタム Application サブクラスで Rx Observables を作成することは許容されますか? 実行する理由は、アプリケーション内に BehaviorSubject を作成し、サーバーから 10 分ごとに変更を要求することです。この Observable をサブスクライブするすべてのアクティビティまたはフラグメントは、変更の最後の状態のみを取得します。

問題は、このアーキテクチャがアプリケーション ライフサイクルの処理と使いやすさの点で安全であると考えられるかどうかです。

更新: 新しいアクティビティが作成され、データを取得する必要があるたびに、ApplicationContext の BehaviorSubject を取得してサブスクライブできます。Subject は最後に発行された値を発行します。なぜ私はこのようにしたいのですか？たとえば、ニュース アイテムがあり、ニュース フィードをフェッチし、ニュース アイテムの完全なコンテンツをフェッチするバックグラウンド タスクを開始したいとします。この場合、ニュース リストをスクロールしている間にデータのフェッチを開始できます。詳細なアクティビティをクリックすると、次のことができます。すでに取得したものから表示するか、ダウンロードするだけです。

複数の Observable をまとめて圧縮し、Observable になるように変換しています。

私ができるようにしたいのは：

flatZip が存在しない場合、これを行う最もクリーンな方法は何ですか (おそらく提出する必要があります)。現時点では、結果自体を flatMap する必要があります。

Rx-Java を使用して、配列内の各項目に対して API 呼び出しを実行しています。すべての操作が完了したら OnComplete アクションを呼び出したいのですが、呼び出されていません。配列項目に対する操作は正常に完了します。