rxjs

0熱

1答えて

http getメソッドを呼び出すと、角度返り値が観測されます。そこで私は50MBのJSONファイルを返すローカルサーバーを作成しました。このファイルには以下のような従業員データがすべて含まれています。 import { Injectable } from "@angular/core"; import { Http } from "@angular/http"; import 'rxjs/a

0熱

2答えて

角度の取得HTTPは観測可能から1つのインスタンスを取得

私のコンポーネントにはバックエンドから同じデータが必要な問題はほとんどありません。だから、彼らはすべてgetDataMethod（）を呼び出します。それは私が約この方法3-4回を呼び出すこの時間の間に5秒で来て、この public getData(): Observable<any> { return this.http.get<any>(this.backendUrl); } 応

2熱

1答えて

同期オブザーバブルを列挙する方法は？

たとえば、観測可能なfrom(['a', 'b'])がある場合、[0, 'a']と[1, 'b']を放出する観測値を取得する方法はありますか？私はfrom('a', 'b').pipe(zip(range(0, Number.POSITIVE_INFINITY)))を試してみましたが、これは無限ループを作成します：あなたは、コンソールでRx.Observable.from(['a', 'b'])

7熱

2答えて

RxJS - 観測対象から最後のn個の要素を取り出す

観測対象から最後の3つの要素を取りたいと思う。のは、私のタイムラインは、このようになっていることを言ってみましょう： --a---b-c---d---e---f-g-h-i------j-> 場所：a, b, c, d, e, f, g, h, i, j are emitted values 新しい値が、私はそれがこのように見えることができますので、すぐにそれを取得したい放出されるたび： [a]

1熱

4答えて

角4 this.http.get（...）。mapは関数ではありません

こんにちは、私は自分のコードに問題があります。 this.http.get(...).map is not a function しかし、私は追加します：このコードは、私はエラーを持っていると import { Injectable } from '@angular/core'; import { Car } from "./models/car"; import { Observable }

2熱

1答えて

放射値に応じてRxJSが繰り返されます

conditionフィールドに返される値によっては、repeatに約束しています。 vが未定義であり、ランダムTypeError: Cannot read property 'condition' of undefined をスローにconsole.logのO/Pは{ Items: [ 1, 2, 3, 4, 5 ], condition: 5, time: 1513827310333 } JSF

0熱

1答えて

サービス経由でカスタム関数からObserverを返す：Angular 4

私はAngularJsで約束したようにAngular4でObserverを初めて使っています。私は2つのシナリオを理解したい： UIをそれに応じて変更できるように関数から観察可能なものを戻す。 UIに反映された関数からのデータの連続ストリームを返します。 proc.component.tsファイルで counter(){ public counterObserver = Observab

0熱

1答えて

mergeMapは以前のHTTP呼び出しをキャンセルします

私はダイアログを開いてダイアログ内のフォームコントロールのデータをプリロードするアクションを送出します。アクションは、元のアクションに渡された配列内の各idのデータをプリロードする新しいアクションの配列を戻すエフェクトによってピックアップされます。 @Effect() preloadReferenceData$ = this.actions$ .ofType(PRELOAD_REFDA

8熱

1答えて

いつ `publishReplay`と` shareReplay`を使うべきですか？

私はすでにも publish株式単一のサブスクリプションとはConnectableObservableが Share()がReplay postfixのはかなりあるpublish().refcount() である（ので、我々はConnect()に持っている）を返すことを知っています明らかに、それは最後の排出量を返します。 publishReplay().Connect() しかし、私は次のことがで

0熱

1答えて

rxJSの配列を平坦化またはマージする方法

私は1つの同種配列にフラット化したい構造体を持っています。ソース配列は、次のようになります。私は次のようになりますにこれを変換したいと思い何 [ { "countryCode": "CA", "countryName": "Canada", "states": [ { "stateCode": "CAAB", "state