rxjs

1熱

1答えて

rxjs：forkJoinは完了するために少なくとも1つの呼び出しを必要としますか？

私はforkJoinしたい2つの観測があります。これらの観測の var goodObservable = Rx.Observable.create(function(observer){ observer.next('something'); observer.complete(); }); var badObservable = Rx.Observabl

0熱

1答えて

Observable combine/Interval/Timerと一致する

私は設定間隔と一緒に.combineLatestを使用して、5秒ごとに新しい値が出力されるようにしています。私は次に、このコンポーネントを子コンポーネントへの入力として渡していますが、入力に渡されるデータは毎回同じです。開発ツールのネットワークタブを見ると、追加の呼び出しは行われません。 .flatMap(() => { return Observable.interval(5000).

0熱

2答えて

switchmapと別のobservables

これを理解しようとするとAngularとRxの新機能...私のアプリはUIイベントに反応し、Observableを返すHTTPサービスを呼び出します。私はそうのようにそれを購読する： this.myXYZService.search(query) .map(r => { // some code }) .subscribe(r => { //some code }); は、

0熱

2答えて

角度観察可能combinelatest

私はテーブルを移入するサービスにアクセスするコンポーネントを構築し、オブジェクトのリストで、観察を返すようにしようとしているは私のサービスは機能を持っています public getTranches(): Observable<Tranche[]> { this.loadTranches(); //this calls the rest API to populate the varia

0熱

2答えて

Observable onCompleteハンドラを提供するための方法がありますか？

チェーンが完全に完了しているときにのみ、私は観察可能なチェーンで働いていると私は、次またはエラー値に興味がないんです。私はonCompleteコールバックを提供することができるので、subscribeメソッドを利用し、次とエラーのために2つのnoopsを供給するのは間違っていると感じます。例については：私が好きな何 let isRunning = true; Observable.from(

1熱

1答えて

角度HttpClientのエラー処理

HttpClientでエラーが発生した後にコードを実行する方法と少し苦労しています。 httpが失敗したときにローディングスピナーをオフにするフラグを設定する方法を知りたいと思います。私は幸せなパスで5 private fetch(): Observable<LegalTerm[]> { this.isLoading = true; return this._http

4熱

1答えて

各インデックスの特定のプロパティが真であるかどうかによって、オブジェクトの配列のオブザーバブルを適切にフィルタリングしますか？

私はStudentというタイプのObservableを持っています。つまり、一連のオブジェクトを観測することができます。学生はプロパティid: numberを持っています。プロパティに基づいて生徒配列のインデックスをフィルタリングする方法を教えてください。例では、$はタイプ観察可能[学生]の観測可能であると私は彼らの「bannedId」に基づいてObservable<Student[]>から学生を

1熱

1答えて

異なるコンポーネントから同じ監視可能な（共有）サブスクリプションを使用して

同じページに2つのコンポーネントがあります。各コンポーネントは、パラメータを持つサービスからのObservableに加入している注文に関するものを表示しています。サービス： getOrders(url: string, query: string) : Observable<any> { return this.http.get(url + "&" + query, this.opt

0熱

1答えて

0.75秒後に解決するRxJS Observableを作成するにはどうすればよいですか？

私はObservableを作成して、0.75秒後に解決したいと考えています。私はこのようにそうしようとしたが、観察可能がすぐに解決されています import { Observable } from 'rxjs/Observable'; import { delay } from 'rxjs/operators/delay'; ... refresh(): Observable<any> {

0熱

1答えて

Observable - > Filter - > Observableとして提供

これらのサービスのメタデータを提供するために他のサービスを利用するAngularサービスを試しています。データオブジェクトは、接続クラスを持つ異なるクラスの人です。（クライアント、コンサルタント、販売関係）私が追跡したい基本的な指標は、クライアントにコンサルタントが割り当てられているかどうかです。（すなわち、不一致）。私は、観察可能なアレイが、私はそうのように私のメタデータサービスにに加入す