rxjs

7熱

1答えて

Angular 2のRxJs ofObjectChangesメソッドのアナログをお探しですか？

私は、このプロパティのすべての変更を探していくつかのことを行うクラスプロパティデコレータを作成したいと思います。どうやってやるの？ RxJsで私はofObjectChanges方法 https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/ofobjectchanges.md を見つけましたが、そ

25熱

4答えて

Angular2：配列をObservableに変換する

サービスからhttpでデータを取得するコンポーネントがありますが、このコンポーネントを表示するたびにAPIバックエンドにアクセスしたくないという問題があります。私は私のサービスがデータがメモリ内にあるかどうかをチェックし、そうであればメモリ内の配列で観測値を返し、そうでなければhttp要求をします。マイコンポーネント import {Component, OnInit } from 'angul

16熱

1答えて

RxJSポーリング

私は、彼は、彼らがネットフリックスのスクロールを解く方法を説明しhttps://www.youtube.com/watch?v=zlERo_JMGCw 29:38 にマシューPodwysockiイベントを見ていました。以前のデータがクリーンアップされ、より多くのデータが追加されたとき（ただし、スクロールバックすると前のデータが再び表示される）私は似てやってみたかったが、私はNetflixのデモコ

11熱

1答えて

Angular2 @ TypeScript Observableエラー

私は入力フィールドを持っており、ユーザーが検索文字列を入力すると、_heroService httpリクエストを行う前にユーザーが少なくとも300ミリ秒（debounce）の入力を待つことを望みます。変更された検索値のみがサービスに渡されます（distinctUntilChanged）。 switchMapは、これらの_heroServiceオブザーバブルを結合し、元のリクエスト順でそれらを再配置

8熱

2答えて

RXJS：集約デバウンス

私のユースケースは以下の通りです：私はときどきバースト的に発生するイベントを受け取ります。バーストが発生した場合、私は一度だけそれを処理する必要があります。 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