問題タブ [rx-java2]

「背圧システム」を作成するのに問題があります。Vertx HttpClient と RxJava を使用しています。外部サービスに対して 6000 のリクエストを行う必要があり、waitingForQueue がいっぱいになるのを避けるために、この外部サービスは送信ほど速く処理できないため、リクエストとレスポンスの間に遅延を置きます。

このジャーニーはバッチ プロセスとして機能するため、1 分かからなくても心配する必要はありません。

ここに私のコード

このメソッドは、このサブグループのリスト (6000) を渡す 24 時間ごとに実行される Observable 間隔から呼び出されます。

しかし、ログを確認した後、リクエスト間に 50 ミリ秒の遅延が見られません

ここに私のログの3つ

これを達成するために何をする必要があるか考えていますか?.

よろしく。

解決

より良い解決策があれば教えてconcatMapください。

リスト内の一部のオブジェクトで失敗する可能性のある長時間実行タスクを実行しようとしていますが、再試行しましたが、オブザーバブルのリスト全体に再サブスクライブします。ネストされたサブスクリプションを実行できますが、間違っているようです。サブスクリプションをネストするよりも良い解決策はありますか?

これが私の実装です：

だから私はカスタムスライダービューにこのリスナーを持っています。onSliderChanged(int percent)ユーザーがスライダーをスライドすると、ビューが呼び出されます。スライダーが変化したときにネットワーク呼び出しをしようとしていますが、スライド時にメソッドが頻繁に呼び出されるため、ネットワーク呼び出しを100万回行いたくありません。このリスナーのコールバックを Observable にするにはどうすればよいですか? オブザーバブルになると、デバウンスを使用して、特定の時間間隔の後にのみ更新できることを知っています。

やってみObservable.create()ましたが、コールバックメソッドを使用していて、それがどのように機能するかわかりません。私はKotlinとRxJava2を使用しています。

RxJavaサーバーからデータを取得するためにのtakeUntil演算子を使用して、最適化されたキャッシュとネットワーク メソッドを実装しようとしています。API からの JSON 応答を解析するために Gson モデルを使用しています。

Gson モデルを使用しているため、サーバーからデータを取得する際に行き詰まります。返されたタイプは、Netwrok リクエストとディスク キャッシュの両方で一致しないためです。

いくつかの方法をテストしてきましたが、うまくいきませんでした。

ApiService.java

inetactor.java

インタラクター.java

キャッシュデータ

Gson モデル パーサー

RequestResponse.java

ありがとう ：） 。

いくつかのオブザーバブルを連鎖させ、実行されたオブザーバブルに応じて何らかのアクションを実行しようとしています。しかし、私は奇妙な行動に直面しました。

この例では、ログは 2 秒ごとに表示されますが、ビューに関するすべての変更は、最後の監視対象が終了するときに行われます。

AndroidScheduler.mainThread() の動作だと思います。この行を削除して、このようなビューで変更をラップすると

行動が正しくなります。誰かがこの動作を説明し、この問題を解決する正しい方法を提案できますか?

PublishProcessor<?>複数のオブザーバーにサービスを提供するためにa を使用します。最初のオブザーバーがいつ購読され、最後のオブザーバーがいつ破棄されるかを知る方法はありますか?