角度＆RxJS5 - HTTP＆ソケット

Question

からのデータを更新し、私は私がする必要があるシナリオがあります。

1. をHTTPが応答したら、同じを使用して、HTTPサービス
2. を呼び出すために
3. 利用ルートのparamsのparamsルートを取得ルートのparamsたびソケットが応答ソケットサービス
4. を呼び出すために、HTTPサービスからの更新データ

理想的には、私はこの私を維持したいと思いますnストリーム。

CombineLatestのみ使用できますか？またはScanオペレータを関与させますか？

this.data$ = this.route.params 
       .switchMap(params => { 
        return Observable.forkJoin([ 
         Observable.of(params), 
         this.http.get('api', { prop1: params.prop1, prop2: params.prop2 }) 
        ]) 
       }).combineLatest(([params, data]) => { 
        this.socket.get('event', { prop1: params.prop1, prop2: params.prop2 }), 
         updateData 
       }) 


    private updateData(data, socketData): any[] { 
     //only returns data = [params, data] 
     //socketData always undef 
     return data; 
    } 

Answer 1

私はあなたの流れを理解する方法から、私はあなたがcombineLatestまたはscan演算子のいずれかを必要とする必要はありません、あなただけの巣2 switchMapsする必要があります。

this.data$ = this.route.params 
       .switchMap(params => this.http.get('api', { prop1: params.prop1, prop2: params.prop2 }) 
        .switchMap(httpResult => this.socket.get('event', { prop1: params.prop1, prop2: params.prop2 }) // assuming socket.get(...) is a perpetual stream 
         .map(socketResult => doWhateverCombinationWith(httpResult, socketResult)) 
         .startWith(httpResult); // not sure if this is required, your question is kind of vague, but essentially this will cause the stream to emit the original httpResult before there is socketData 
        ) 
       );