rxjs

1熱

3答えて

私は、オブザーバブルオブジェクトのプロパティを更新する必要があります。私はそれを動作させることができたが、私はそれをどうやって行ったのか本当に好きではない。 next(filter$: BehaviorSubject<GridCollectionFilter>, collection: GridCollectionModel<any>) { let filter = filter$.va

0熱

1答えて

RX.JS Redux Observable複数の同時取得リクエスト同時に

現在、ロケーションIDの配列を受け取っているオブザーバブルを設定しようとしていますが、これらのすべてのリクエストを一度に取得して、すべてのレスポンスを待っています。ここではサンプルです：は [ { id: "aoeuaeu", name: "Test" }, ... ] 私が今持っている問題は、私がリクエストの1に404を取得し、それがす

1熱

1答えて

間隔でオブザーバブルを作成する方法

誰も等間隔でアイテムを放出するオブザーバブルを作成する方法を知っていますか？唯一の捉え方は、常に最初に返される要素です。ここは私の現在のコードです。私はすぐに返される最初の要素が必要です。 var source = Rx.Observable.interval(2000); source.subscribe(function(item){ console.log(item); }

1熱

1答えて

リアクション拡張で.pluck（）メソッドが正確に行うこと

正確にはpluck()メソッドとは何かを理解する必要がありますが、このコードは例示的なものですが、角度4のプロジェクトで試したところ、期待通りに動作しませんでした： source: any = Observable.of([ { value1: 2, value2: 5 }, { value1: 0, value2: 7}, { value1: 1, value2:

0熱

1答えて

Rxjsは配列の振る舞いに対してswitchmapを複数回実行します

基本的には、すべての著者の書籍を入手し、各著者のすべての書籍を入手することです。私はこれのための演算子を見つけることができませんでした。より良い説明のためのコード：これに伴う問題は、そのswitchmapがある this.actividadService.getActividades() .switchMap((result) => { const actividadUno = re

0熱

1答えて

rxjsのテスト：要素を偽装して、結果のストリームを大理石の図でチェックする方法は？

私の目的：私は、そのメンバーにクリックの指示の流れを放つビューコンポーネントを持っています。ボタンをクリックすると、すべてのインタラクティブな要素の期待された順序で命令が出ることをテストします。私は同じ観測可能に文字列'a'と'b'を放出しなければならないボタンaとb、小さな例をまとめました。 import $ from 'jquery'; import { TestScheduler

1熱

1答えて

Rxjs ObservableとAsync Pipeを使用してAngular 4で日常的に繰り返されるイベントのカウントダウンタイマーを作成する方法

Rxjs ObservableとAsync Pipeを使用してAngular 4で毎日繰り返されるイベントのカウントダウンタイマーを作成しようとしています。ここに私のコンポーネントである：ここでは interface Time { hours: number; minutes: number; seconds: number; } @Component({

0熱

1答えて

名onUnsubscribe

このエラーCannot find name onUnsubscribe 私は何をインポートする必要がありますガット見つけることができませんか？ import { Component } from '@angular/core'; import { Observable } from 'rxjs/Observable'; @Component({ selector: 'app',

0熱

1答えて

rxjsはサブスクライブ中に値を返します

export function singleMapServiceFactory(mapServiceFactory: MapServiceFactory) { return mapServiceFactory.switchSingleMapService().subscribe((service)=>{ return service }) // retu

0熱

1答えて

redux-observableでforkJoinを正しく使うには？

私はredux-observableを使用しています。すべての添付ファイルを別々にアップロードした後にメールを送信しようとしています。このプロセスは、メールAPIを送信はドラフトからメールを送って、一旦全ての添付ファイルがアップロードされているドラフトに別々に添付ファイルを追加ドラフトにメールの内容を追加しています以下のコードは、すべての添付ファイルを個別にアップロードすることができ