問題タブ [reactive-extensions-js]

みなさん、私はRxJSを使ってマウスイベントを処理するアプリを持っています。これらのイベントを、より複雑な観察可能な「ジェスチャー」に構成しています。そのようなジェスチャーの 1 つが「シェイク」です。

私が作成しようとしている一連のイベントは次のとおりです。

私が見つけているのは、

も同じ結果を引き起こしています。

codepen の問題を示すフィドルを作成しました。

一般的な私の質問は次のとおりです。マウスアップなどのオブザーバブルがオブザーバブルの構成をキャンセルして再開する必要があることをRxJSでどのように表現しますか?

問題の別の例 (同じフィドルから) として、次のイベント

3 回のシェイク イベントが発生します。一つに結実させたいと思います。

私のシステムでは、ソース、ソースを新しい値にマップする 2 つの「ステップ」、およびそれらの 2 つのステップを組み合わせて最終的な値を作成する合計があります。このシステムの最初の実行は期待どおりに機能し、単一の合計 3 が生成されました。

出力:

しかし、次に source に新しい値を入力すると、次のような 2 つの結果が得られます。

1 つ目は中間結果です。新しいソース値がシステムの一部を通過し、すべての値の伝播が完了すると最終結果が得られます。

私の質問は、ソースにプッシュされた新しい値がシステムをアトミックに通過し、1 つの合計結果のみを生成するように構成するための推奨される方法は何ですか?

ありがとう！

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

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

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

試した

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

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

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

$createObservableFunction メソッドを使用してオブザーバブルを作成し、そのオブザーバブルを複数回サブスクライブするとします。最後のサブスクライバーは、他のサブスクライバーをオーバーライドします。

ただし、 rx.Observable.interval() でオブザーバブルを作成し、それを複数回サブスクライブするとします。両方のサブスクライバーが間隔で起動します。

なんで？さらに重要なのは、$createObservableFunction を取得して両方のサブスクライバーを起動するにはどうすればよいかということです。

問題を説明するプランカーの例。http://plnkr.co/edit/kXa2ol?p=preview

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

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

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