rxjs5

1熱

1答えて

サービスから返されたObservablesが2つ（それぞれObservable.just()と考える）の1つしか返されません。それぞれが異なるタイプのものです（タイプが重要なので、タイプ・スクリプトで書いています）。すべてのObservableが（約束の用語を使用して）解決されたかどうかを知る方法はありますか？失敗を個別に処理して実行する必要があります。不自然な例： const obs1 =

2熱

1答えて

RxJS Observableでcache throught `.publishReplay（）`のタイムアウトを設定する方法は？

しばらくの間結果をキャッシュするObservableを作成しました。この例はすばらしい、非常に便利です！しかし、アイテムプロデューサのタイムアウトを設定できませんでした。 mockDataFetch()のタイムアウト演算子を使用しようとしましたが、最初に失敗した項目の後にストリームを復元できませんでした。タイムアウトでmockDataFetchを達成するにはどうすればよいですか？これは私がやっ

1熱

1答えて

rxjsバッファが私のために期待どおりにスロットルで動作しない

スロットリングされたエミッションに基づいてバッファリングされたエミッションを作成しようとしています。次RxJs 2に期待されるような作品： .buffer(function() { return clickStream.throttle(250); }) full jsfiddle example here しかし、私は私の地元のプロジェクトでこれを使用しようとしたときには、次のエラーが返され

0熱

1答えて

Rxのプリフェッチロジック

rx.jsに自分のプリフェッチロジックを実装しようとしています。ここでは例の大理石の図である。次のように私はこの問題をモデル化しました：私のプログラムは、ユーザーがクリック特定のリンクにしたいかもしれないことを知ることができますヒントの流れがあります。ただちにリクエストを送信したいと思いますが、のユーザーが実際にリンクをクリックした場合のみレンダリングします。これに基づき、ユーザーがリンクをク

3熱

1答えて

RxJS5 - オブジェクトマップを配列に変換する演算子

オブジェクトマップを返すサービスがあり、これは配列をとるAngularのngForで使用されます。したがって、私はlodashの_toArrayでマップ演算子を使ってデータを配列に変換しています。これは機能しますが、私はこれを行う必要があるすべての場所でlodashをインポートする必要があり、脆いようです。私はカスタムオペレーターを作ることに目を向けようとしていましたが、すでにこれを行っているオ

3熱

3答えて

角度2でrxjsを使用して間隔で非同期を要求する方法

rxjsを使用してhttp要求で間隔を設定したいとします。リクエストが完了してからn秒後にサーバー上のデータを送信する必要があります。 Observable.interval(10000) .?(() => { //request for server. return Observable return this.getData();

1熱

1答えて

Rxjs：約束を再試行しますか？

なぜ私の約束は解決しているのですが、再試行しようとしています。 var getResultsStream = url => Rx.Observable.onErrorResumeNext( Rx.Observable.defer(() => Rx.Observable .fromPromise(getSearchResults(url) .catch(error

3熱

1答えて

rxjsのfromSubscriberの実装

今日は面白い問題に遭遇しました。私はファイルをアップロードしているアプリケーションに取り組んでおり、プログレスバーを実装したいと思っています。このアプリは、React/Redux/Redux-Observableを使って書かれています。アップロードの進捗状況に応じてアクションをディスパッチしたい私はそれを実装するために何をしたのですか： withProgress(method, url, body

5熱

1答えて

変数の変更を検出する方法は？

私は変更を定期的にチェックする必要があるグローバルスコープの変数を持っています。これは私が簡単なJSでそれを行うだろうかです：それは Observablesを使用して行われている方法 let currentValue, oldValue; setInterval(()=>{ if(currentValue != oldValue){ doSomething()

1熱

1答えて

約束の値の変化を検出する方法は？

約束を返し、解決された値の変化を検出する関数をポーリングしたいと考えています。私は何とかここにinterval演算子を追加する必要があります。 const observer = (newValue) => { console.log('Change detected', newValue); } Observable.fromPromise(getValue()) .di