問題タブ [rxjs]

配列アイテムがあるとしましょう

を使用して、この配列からオブザーバブルを作成できることを知っています

これから怠惰に無限に繰り返すオブザーバブルを作成するにはどうすればよいですか (つまり、要求されている限りアイテムを繰り返します)?

試した

しかし、これは遅延して実行されないため、ブラウザがロックされます。

JavaScript に Reactive Extensions を使用することに確信が持てたので、次のように Mongoose で使用しようとしています。

しかし、何も起こりません。私は何を間違っているのでしょうか？

Facebook のような「xyz が入力中」機能を備えたチャットを作成したいと思います。

ユーザーが入力をやめたときに、このスニペットを使用して登録します。

e を想像してください。

そして、私のストリーム/サブスクライバーは

これは、ユーザーとユーザーが入力している会話を登録するすべてのキーダウンに対して意味します。

RxJS を使用して、それぞれ約 1 GB の数百のログ ファイルを処理するスクリプトを作成しようとしています。スクリプトのスケルトンは次のようになります

コードは機能しますが、すべてのログ ファイルのフィルタリング手順が同時に開始されることに注意してください。ただし、ファイル システムの IO パフォーマンスの観点からは、ファイルを 1 つずつ処理することをお勧めします (または、数百のファイルすべてを同時に開くよりも、少なくとも同時実行を少数のファイルに制限することをお勧めします)。この点で、「機能的なリアクティブな方法」で実装するにはどうすればよいですか?

私はスケジューラを考えていましたが、ここでどのように役立つかわかりませんでした。

RxJ で switchLatest と flatmapLatest の違いを確認するのが困難です。違いは、ネストされたオブザーバブルを scala のようにフラット化し、もう 1 つは新しいフラット化されたコレクションを返す前にそれを行うのと同じですか?

私は何かが欠けていますか？

これについて私がどれほど正しいかはわかりませんので、専門家がこれについて私を修正できる場合は、それも高く評価されます. 私の現在の理解では、オブザーバブルは怠け者であり、サブスクライブするまで値を生成しません。エラーが発生した場合、オブザーバブルはそれ以上値を送信しません。多くの場合、これは望んでいるものではありません。

以下のコード サンプルでは、​​パースとロンドンの天気を取得しています。エラーが発生した場合は、エラーが発生したことを示すオブジェクトを返します。これは、サブスクライバーのエラー ブロックが呼び出されないことを意味しますが、成功は呼び出され、失敗したかどうかを確認してロジックを変更する必要があります。これはこれを行うための最良の方法ですか？

また、zip 演算子は、順序に関係なくすべての obs が値を生成するのを待機し、すべてから単一の値が生成されたときに戻りますか?

以下のようにコードします。

提案やヒントは大歓迎です。

前もって感謝します。

ブレア。

SelectMany の動作は、生成された各値の結果を単一のストリームに効果的にマージすることであるため、順序付けは非決定論的であることを理解しています。

C# の RxJs で concatAll に似た処理を行うにはどうすればよいですか。

これは事実上、私がやりたいことです。範囲が与えられた場合、それぞれを少し待ってから、開始した順序で連結します。明らかにこれはおもちゃの例ですが、アイデアはそこにあります。

ブレア

各オブジェクトにプロパティを追加して、非同期的に変更する必要がある一連のオブジェクトがあります。

これに相当する同期は次のようになります。

ただし、私の場合、fooプロパティを非同期的に追加する必要があります。fooプロパティが追加されたオブジェクトのシーケンスを終了値にしたいと思います。

この問題を解決するために、次のコードを思いつきました。この例では、各オブジェクトに の値を持つプロパティを追加していますbar。

これは私の問題を解決する最良の方法ですか、それとも Rx はシーケンス内のオブジェクトを非同期的に変更するためのより良い手段を提供しますか? 変更する必要がある深いツリーがあり、このコードはすぐに扱いにくくなるため、よりクリーンなソリューションを探しています。

そもそも、この突然変異を行うべきではないのでしょうか?