rxjs

0熱

2答えて

次の観測値の作成に問題があります。あらかじめ定義された値の配列を受け取るようにしたいそして、私は別のものでフィルタリングし、これらを個々の観測値として扱うことができます。私は私は私の質問に十分な特異的ではなかった申し訳ありません：その後、そして、それはこれらのフィルター観測をマージする時間が来るとき、私は、元の1つの //Not sure the share is necessary, ju

4熱

1答えて

observableの複数の最新バージョンを組み合わせると、

はcomments,attachments,imagesとなります。これらのアイテムはすべてngrxストアから取得されます。つまり、これらのアイテムはすべてオブザーブ可能です。私の質問は、どのようにそれらのアイテムを組み合わせるのですか？は通常、私は何をすべきかを使用することである： combineLatest(selectProducts, selectProductComments, (pr

3熱

1答えて

forkJoinがAngularFire2のvalueChangesで動作しない

私が苦労している問題を解決するのを手伝ってください。私は私が何をしようとしているFirebaseオブジェクトキー const keys = ['-Kx9pqoMWlJLbKLQcAkP', '-Kx9pqoOYlDHTJ64Was5'] の配列を持っているがforkJoinを使って一つのストリーム内のすべてのものをFirebaseのオブジェクトを取得することです。ここで私が持っているものです

0熱

1答えて

折り返し角4観察可能なHTTP呼び出しを1つにキャッシングするためにObservable

私はAngular 4アプリケーションを持っています。これはシステムのダッシュボードとして機能します。複数の異なるコンポーネントが、同じTypeScriptサービスクラスを使用して同じバッキングREST呼び出しを呼び出します。これがうまくいく間に、クライアント側にキャッシュサービスを導入することで、サーバを叩く不必要な重複リクエストストームを回避したいと思います。私は、HTTPがcompute

3熱

1答えて

購読していない共有オペレータ

開始するには高価なので、いくつかの無限ストリームを読み込む必要があります。そして同じ理由で彼らが始まったら、私は彼らを止めたくない。 share演算子があった場合、下位の加入者がすべて退会していても、最初に購読された後に下位のストリームから退会しなかったと思っています。今私は、公開2つの異なるラインに接続し、大丈夫働くとそれをやっているが、同じように非常にrxjs不格好思わない：私はそれが最後に

-2熱

1答えて

観測可能なデータが保持されません

私がconsole.log(this.distances)になると、利用可能ですがメモリには格納されません。どのように私はそれを使用するメモリに格納することができますか？データの後に関数を実行しても、配列のエラーはまだnullになります。 findClosestRiderToUser() { this.fetchAllRiders().subscribe(async distance =

0熱

1答えて

サーバーからデータを取得する方法は？区間演算子を使用する

リモートサーバーからデータを取得します。 CORSが設定されています。私は、interval（）演算子形式のRXJSライブラリを使用します。コンポーネント： import { Observable } from 'rxjs/Observable'; import 'rxjs/add/observable/interval'; import 'rxjs/add/operator/switchM

0熱

1答えて

完全装填時のデータ可能性？

Primeng dataTableを使用してバックエンドからのデータベースクエリ結果を表示していますが、列と行が表示されたらイベントが発生していますか？もっと長い質問ですが、バックエンドを照会している間に画面をブロックしようとしましたが、リクエストが戻ったときに画面のブロックを解除していましたが、画面がブロックされていて（要求が返されました）画面（行と列が表示されます）、我々は100〜500ms

2熱

1答えて

すべてのオブザーバが順番に実行されるのを待つ方法を教えてください。

私はforkJoinがすべての観測値の観測を待っていることを理解していますが、観測値が順番に発生する必要があります。私は、連結の使用を誤解されるかもしれないが、私たちのコードは次のようになり、この多かれ少なかれ： const observables: Observable<ArrayBuffer>[] = []; observables.push( Observable.fro