問題タブ [reactivex]

Observableがあるとしましょう:

どうすればそれを完全にすることができますか (サブスクライブされたすべてのオブザーバーのonCompleteイベントをトリガーするものは何ですか) ?

Observables を使用してループ内でこの if/else 条件をリファクタリングする方法を理解するためにいくつかの問題があります。

これが私のコードです：

次のようなものが欲しい

しかし、if/else の表現方法がわかりません。

助言がありますか？

よろしく。

Observable をグループ化し、各 GroupedObservable から最後に発行されたアイテムのみをメモリに保持する方法は? 各グループが BehaviorSubject と同じように動作するようにします。

このようなもの：

したがって、メモリには、それぞれの最後のアイテムしかありませんuser。

サブスクライバーがサブスクライブすると、これら 2 つのアイテムがすぐに発行されます (それぞれが独自の発行で)。それぞれに BehaviorSubject があったようにuser。

onCompleted() は、人々が永遠にチャットする可能性があるため、起動することは想定されていません。

userどのような値が存在する可能性があるかは事前にわかりません。

次のようなコードが存在すると仮定します。

Rx をフロントエンド コードに適用しようとしました。

そして、それは適切に機能しています。

しかし、サブスクリプションを にバインドすると、IObservable途中でデータを取得し続けるのを止める方法はありますか? サブスクリプションを破棄しても、列挙は停止しません。

サーバーを実行している RC に問題があります。私の統合テストは、この1つの起動前にサーバーにヒットしています。テストを開始する前に、サーバーのポートが実際にリッスンしていることを確認するにはどうすればよいですか?

httpServer.listen(port, handle) 機能を使用していましたが、API の指定どおりに機能しないようです。

助言がありますか？

RxJについていくつか理解しようとしています。私がやりたいことは、いくつかの JSON データを消費し、そのデータが入ってくるとすぐに DOM でそのデータのレンダリングを開始することです。ストリームの要求、応答、および表示をセットアップしました。それはすべてうまく出力していますが、時間の経過ではなく、一度にすべて実行しています。

ファイル全体が完了するのを待ってから一度に表示すると、長い待ち時間が発生するのではなく、ページにデータが入ってくると表示を開始したいと考えています。

私はreactiveX Zipでいくつかの実験を行っていましたが、zip内で定義したオブザーバブルが次々と順番に実行されることに気付きました。zip の良い点は、zip 内で定義されたすべてのオブザーバブルが 1 つのスレッドで実行されるため、すべてが並列に実行されることだと思いました。私が望むものを達成する方法はありますか?. これが私のzipの例です

300ミリ秒ごとに発行されるイベントを処理するための固定スレッドプールを作成し、プロセスに1000ミリ秒が必要であると想定しています。マルチスレッドは機能するが、再利用されるスレッドは 1 つだけだとします。

sleepTime を 300ms 未満に設定すると、処理スレッドが変更されますが、それは役に立ちません。

質問: 同時実行するにはどうすればよいですか? プログラムがスレッドを再利用するのはなぜですか?

前もって感謝します

ログ