問題タブ [rxjs]

特定のコンポーネントからの送信変更フィードである Rx ストリームがあります。

onNextに渡されたアイテムが蓄積され、バッチ モードが終了したときにのみ渡されるように、ストリームでバッチ モードに入ることができるようにしたい場合があります。

通常、ストリームを介して単一のアイテムを渡します。

onNextに渡された項目とsubscribeで受信された項目の間には 1 対 1 のマッピングがあるため、前のスニペットでは、値 1 と 2 を使用してsubscribeを 2 回呼び出すことになります。

私が探しているバッチモードは、次のように機能する可能性があります。

この場合、サブスクライブが単一の連結配列 [1, 2] で 1 回だけ呼び出されるようにします。

繰り返しますが、バッチ モードが必要な場合は、連結されていないアイテムを渡す場合もあります。

Rx でこの動作を実現するにはどうすればよいですか?

注: 以前はonNextを介して配列を渡していましたが、これはほとんどの場合、個別モードでもバッチ モードでも型が同じになるようにするためです。

例えば：

Subscribe は [1, 2, 3] の次に [4, 5, 6] を受け取りますが、バッチモードでは、Subscribe は連結された結果 [1, 2, 3, 4, 5, 6] を受け取ります。

したがって、このように見ると、非連結モードと連結モードに似ています(個別モードとバッチモードではなく)。しかし、問題は非常に似ていると思います。

RxJs を使用して、特定の時間枠に到着するパケット数をカウントしています。私のコードは基本的に次のようになります。

Rx TestScheduler を使用してこのコードを単体テストする方法は? サブジェクトのテストに適した例が見つかりませんでした。

このような配列の配列がある場合

そして、すべての子が処理されるまで (長い非同期プロセス) 次の親を開始しないように、各親とその子を順番に循環させたいのですが、RxJS でこれを行うにはどうすればよいですか?

私はこれを試みました：

しかし、私はすべての親をログアウトさせてから、すべての子供をログアウトさせます。

Rx.Observable.fromEvent(element, eventName)イベントをキャプチャする要素として jquery セレクションを使用する例はたくさんあります。ただし、Rx が jQuery を使用してフィルター処理されたイベント設定からのイベントのみをリッスンすることは可能ですか?

私は効果的に似たものを思いつきましたが、jquery フィルターよりもはるかにコストがかかるようです。

jQuery バインディングをエミッターに変換し、そのイベント ストリームを Rx で使用する方法はありますか? 最善のアプローチは何ですか？

こんにちは、 RxJSを使用して既存の JSON オブジェクト/配列を検索できるかどうか疑問に思いましたか? Ajax リクエストの例のみが表示されます。JSON は既に読み込まれていますが、RxJSを使用してフィルタリングしたいと考えています。

良い例はありますか？それが可能であることを願っています:)

共通メッセージ バスからのどのイベントをサーバーに送信するかを制限しようとしています。許可されたイベントはoutgoingEvents配列にあります。問題は、それらを適切にサーバーに送信するには、イベント名が必要なことです。

Bacon.js の Bus のように、イベントを直接プッシュできる Observable を作成するにはどうすればよいですか?

したがって、基本的に、私の問題は、プログラムの開始時に、jQuery.css()が正常に動作し、次のようにテストされていることです。

その直後に、必要なときにいつでも追加される div を追加しようとすると.css()、その要素に対して機能しなくなります。このような：

これは、スタイルなしで を追加するだけで<div class="circle"></div>、後で.remove()'d-

フィドル: http://jsfiddle.net/bh79fe87/

完全なコードは次のようになります (LiveScript):

また、HTML：

私は、combineLatest を使用して、2 つのストリーム A と B を結合しています。

ストリーム A が値を生成する場合、それを B の最後の値と結合し、結果ストリームに値を生成します。

ただし、呼び出しごとに B の最後の値を忘れて、次に A が選択されたときに、結果ストリームが新しい値を生成するために新しい B を生成する必要があるようにしたいと考えています。

これを対称にしたいので、逆も同様です。

例：

私はこの答えを見つけました： RXを使用してイベントストリームを調整する方法は?

ただし、RxJSの答えが必要な間はC＃で書かれています。