rxjs5

1熱

2答えて

の場合、私はngrx効果を使用するように移行していると私は、次の問題があります。dispatch戻りvoidので、私はエラーが私から発生した場合、ルータのナビゲーションを防ぐ方法がわかりませんngrx効果（例えば、this.userAccountService.updateFirstName(...から）。私のコンポーネントクラスから：私の効果クラスから updateFirstName() {

8熱

3答えて

rxjs 5 publishReplay refCount

publishReplay().refCount()の仕組みを理解できません。例えば（https://jsfiddle.net/7o3a45L1/）：コールobserverA：5 observerB：5コールobserverB：5 observerC：5 var source = Rx.Observable.create(observer => { console.log("call

0熱

1答えて

RxJSとの非同期アクションの同期

RxJSの概念の詳細を理解したいと思います。私が現在苦労している問題はここにあります。私は非同期呼び出しでDBへのアクセスを抽象化したいと思います。私はアクセスを同期したいと思います。は、私はアクションのストリームを持つことができ、 - 非同期を行うをDBへの格安通話 - のための観測を得るものとするアクションの呼び出し元 - 私は、以前のアクションがを完了するまで、次の行動が遅れることがし

1熱

1答えて

RXJS - 例外：Rxが定義されていません。2

APIコールを呼び出してオブザーバブルを返すangular2サービスがありますが、RXJSはEXCEPTION：Rxが定義されていないというエラーを返しています。何をインポートする必要がありますか？もちろん、フォルダ全体をインポートする必要はありませんか？！---輸入 import 'rxjs/add/observable/from'; import 'rxjs/add/operator/ma

0熱

1答えて

RxJS

ここで条件（グローバル変数の存在）が満たされたときに期待されると、観察完成に結果として働いていたコードのレガシー約束ベースの作品です： const fooPromise = new Promise(resolve => { const interval = setInterval(() => { if (window.foo) { clearInterval(int

2熱

1答えて

RxJS 5 filter：2 combineLatest

Angularを使用して、サーバーからのデータのリスト（配列）を表示しています。リストの上にbutton barとdropdownがあり、ユーザーはfilterのリストを許可します。私は2 Subjectsを作成し、このような流れの中combineLatestを使用：これは動作しますが this.http.get('/api') .combineLatest(this.firstFil

19熱

3答えて

HTTPサービスのリアクティブキャッシュ

私はRsJS 5（5.0.1）を使用して角2でキャッシュしています。うまく動作します。キャッシュ機能の肉は、次のとおりです。 const observable = Observable.defer( () => actualFn().do(() => this.console.log('CACHE MISS', cacheKey)) ) .publishReplay(1, t

5熱

5答えて

`Rx`からObservableをインポートする方法（角度でない）

SystemJS私はes2015プロジェクトをブラウザに読み込みます。これは私がObservableがundefinedである。この場合、 import {Observable} from 'rxjs/Rx'; const button = document.querySelector('button'); const start$ = Observable.fromEvent(butto

1熱

2答えて

RxJSはx秒ごとに配列から値を出力し、その値を持つ関数を呼び出し、失敗した場合は再試行します。

配列を持っていますが、値の型は無関係です。私がしたいのは、x秒ごとに1つの値を出すことです。その値を持つ関数を呼び出すと、その関数が何らかの理由で失敗した場合は、y秒後に再試行します（単純な定数、ここではインクリメンタルなものは必要ありません）。私はここにかかわらず、これまで Rx.Observable .interval(500) .take(arr.length)