rxjs

8熱

2答えて

私のユースケースは以下の通りです：私はときどきバースト的に発生するイベントを受け取ります。バーストが発生した場合、私は一度だけそれを処理する必要があります。 Debounceがこれを行います。しかし、debounceは私にバーストの最後の要素を与えますが、バースト内のすべての要素について（フラットマップを使用して）集約する必要があります。これはタイムドウインドウまたはバッファで行うことができま

6熱

2答えて

RxJS 5.0「do while」のようなメカニズム

単純な短いポーリングにRxJSを使用しようとしています。サーバー上のpathの位置にdelay秒ごとに1回要求する必要があります.2つの条件の1つに達すると、コールバックisComplete(data)がtrueを返すか、サーバーを試しました。maxTriesを超えました。ここでは基本的なコードは次のとおりです。 newShortPoll(path, maxTries, delay, isComp

9熱

1答えて

TypeScriptはRxJS定義でIPromiseという名前を見つけることができません

タイプ定義をインポートするのにtypings、タイプスクリプトをインポートするのにgulp-typescriptを使用しています。私は私の活字体のタスクを実行すると、私はRxJSのタイピングで使用IPromiseとIDisposable種類についていくつかの警告が出ます： typings/main/ambient/rx/index.d.ts(34,20): error TS2304: Cannot

5熱

3答えて

最初と最後のデバウンス演算子

最初と最後のデバウンスされたイベントを得るためにrx演算子の組み合わせはありますか？これは、最初に選択したアイテムを直ちにロードし、最後のユーザーが選択を変更しないようにする、マスター詳細シナリオ（またはシナリオのシナリオ）で使用されます。これにより、ユーザがゆっくりとナビゲートするときにデバウンス時間が注入されるのを防ぎますが、変更のバーストも防止します。 debounceオペレータがund

5熱

2答えて

Javascriptによるリアクティブプログラミング

私はリアクティブプログラミングでは新しいですが、私は理解できないこれらすべての記事を少し読んでいます。実際、Nodejs、Angularjs、Angular 2、Reactのjavascript開発者です。私は何私は、コールバックより良いテスト容易性...リモートデータフェッチ、ローカル非同期解像度などのために、約束のすべての時間を使用して、私のニーズに合います。私はストリームは、特定の場

5熱

2答えて

角度サービス内のSubject.asObservable（）の現在の値を取得

Angular2サービス内に単純なトグルを書きたいと思います。したがって、現在の値はSubjectです（下記参照）。 import {Injectable} from 'angular2/core'; import {Subject} from 'rxjs/Subject'; @Injectable() export class SettingsService { priv

9熱

2答えて

Angular2：マウスイベント処理（現在の位置に対する相対移動）

私のユーザーは、キャンバス内でマウスでオブジェクトを移動（または回転）できる必要があります。マウスイベントが発生すると、最後のイベントまでのデルタ（方向と長さ）を計算するために画面座標が使用されます。特別何も... マウスダウン（第1の座標取得）のMouseMove（n番目deltaXYによってオブジェクトを移動、deltaXYを計算し、座標取得）ステップ2と同様のmouseup（とのMous

1熱

1答えて

rxjs - observableとobserverを理解する

私はobservableとobserver（rxjs）の周りに頭を浮かべることができません。私はobservableがobserverにメッセージを送り、observerはobservableを購読できますが、私はURLを要求したいと言いますが、ユーザーが初めて "loadData"を呼び出し、データがHTTPリクエストからロードされ、クラス内でローカルに保存されたときに、次回ユーザーが "lo

8熱

2答えて

AngularJs - RXJS Observable unsubscribe

私は、観測可能なRXJSをセットアップしました。私は、サービス工場の科目を購読する2つのコンポーネントを持っています。選択したコンポーネントをサブジェクトに登録解除して、ボタンを押すとサブジェクトのブロードキャストの受信を停止するにはどうすればよいですか？ Unsubscribe App に私のコードを私のjsfiddleを参照してください： <div ng-app="myApp" ng-cont

0熱

2答えて

Streamsのこのシーケンスを作成する方法はありますか？

私はこの大理石図を実装しようとしていますが、hipotesisはN個のsN $を持っており、このストリームをメイン$に追加しています。 s1$ +--1--------------------99---------------------> s2$ +------3--------7------------------------------> main$ +---[1]-[1, 3]---