rxjs

19熱

2答えて

RxJs 5 share()オペレータの動作は100％わかりません。latest docsを参照してください。質問hereのJsbin。 Iは0〜2の一連の、二番目で区切られた各値と観測可能なを作成する場合： var source = Rx.Observable.interval(1000) .take(5) .do(function (x) { console.log('some

5熱

1答えて

RxJSを使用した要求ストリームからの同期ストリームのストリーム

RxJSを初めて使用していて、誰かが私を助けてくれるのだろうかと思っていました。リクエストのストリーム（ペイロードデータ）からレスポンスの同期ストリーム（できれば対応するリクエスト）を作成したいと考えています。私は基本的にリクエストを1つずつ送信し、それぞれ最後のリクエストからの応答を待っています。私はこれを試してみましたが、それは一度にすべてのもの（jsbin）送信：jsbin（限り、 v

13熱

4答えて

Promise .all（）with RxJS

私はAngular 2でアプリを書いています。私はいくつかのHTTPリクエストを実行し、レスポンスに対して関数を実行したいと思います。アンギュラ1では、私は$q.all([$http.get(...), $http.get(...), ...]).then(doSomethingWithResponses); のようなものしかし、角度2つのリターンRxJS観測を記述し、読書の束の後、私はまだいく

11熱

1答えて

RxJs Observable Pagination

最初：これは私がRxJsを使用している最初のプロジェクトです。私はそれを使ってベストだと思っていました。私はこの答えが見つかりました：Turning paginated requests into an Observable stream with RxJs をしかし、それはコメントで述べている：あなたはまだ最大コールスタックを超えています。約430ページが返されました。私は再帰がここで最善の

5熱

2答えて

角2遅れてマウスイベントがまだアクティブであるかどうかを確認します。

私は、ディメンションを作成するために角2を使用しています。私は、次のイベントは、ホストコンポーネントにバインドされています：私はまた、2つのイベント export class PopupDirective { private _mouseEnterStream: EventEmitter<any> = new EventEmitter(); private _mouseLeav

5熱

1答えて

BehaviorSubjectフィルタは関数ではありませんか？

エラーは、次の行に$を次のように定義されて let load = this.actions$.filter (action => return action.type==START_LOADING); アクション追加 https://plnkr.co/edit/JHODQeWQtYmz4UkYzFds?p=preview :(私のplunkerが動作しない理由を把握しようとしているいくつかの時

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オブザーバブルを結合し、元のリクエスト順でそれらを再配置