rxjs

7熱

2答えて

Observablesを使用してカウントダウンタイマーを作成しようとしていますが、http://reactivex.io/documentation/operators/timer.htmlの例は機能していません。この特定の例では、timerIntervalに関連するエラーは、Observableの関数ではなく、timerから返されます。私も他のアプローチで実験してきたし、私が思い付くした最高の

9熱

2答えて

Angular2 Observables - Replay

最新の値を再生するAngular2 Observableを設定しようとしています。 import {Injectable} from 'angular2/core'; import {Observable} from 'rxjs/Observable'; @Injectable() export class RefinementService { refining: any;

24熱

1答えて

角度2 - 1つの観測で複数のサブスクリプションを扱う

私はAngular 2アプリで作業しており、認証エラーをきれいに処理する方法についてのガイダンスが必要です。私の最終目標は、Httpリクエストごとに認証エラー（特に401と403）を集中的に処理できるようにすることです。私はthis質問のスーパーが私を始めてくれて助かりましたが、自分のカスタムHttpの実装で返された各オブザーバブルのエラーハンドラを登録する適切な方法については固執しています。

5熱

3答えて

RxJSとWebWorkers

クイック質問私はその後、観察可能に加入している場合、バックUIコードにObservable<Any>を返す関数を持っているWebWorkerを持っている場合は、UIスレッドまたはWebWorker上で観察動作しています糸？私はUIスレッド

19熱

2答えて

RxJs 5のshare（）演算子はどのように機能しますか？

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が動作しない理由を把握しようとしているいくつかの時