Ionic2で複数の$ httpリクエストをインターバルで受け取る

Question

複数のhttpリクエストを1つの観測可能なものにフォークし、間隔で呼び出し、すべてのサブスクライバ間で同じデータを共有したい。

私のコードは、これまでのようになります。

import {Observable} from "rxjs/Rx"; 

let obs = Observable 
    .interval(10000) 
    .publish() 
    .connect() 
    .forkJoin(
     this.http.get(API_URL + "x", {headers: this.headers}) 
     .map(response => response.json()), 
     this.http.get(API_URL + "y", {headers: this.headers}) 
     .map(response => response.json()) 
    ) 
    .map(res => { 
    // do some stuff 
    return res; 
    }); 

エラー：私が読んだ

Typescript Error 
Property 'forkJoin' does not exist on type 'Subscription'. 

：

https://blog.thoughtram.io/angular/2016/06/16/cold-vs-hot-observables.html

Multiple $http requests in Ionic2

http://restlet.com/blog/2016/04/12/interacting-efficiently-with-a-restful-service-with-angular2-and-rxjs-part-2/

ありがとう！

Answer 1

このような何か作業をする必要があります：次に

let source = Observable 
    .interval(1000) 
    .flatMap(() => { 
     return Rx.Observable.forkJoin(
      this.http.get(API_URL + "x", {headers: this.headers}) 
       .map(response => response.json()), 
      this.http.get(API_URL + "y", {headers: this.headers}) 
       .map(response => response.json()) 
     ) 
    }) 
    .publish(); 

source.connect(); 

オブザーバーは、この観測可能

source.subscribe(...); 

私はここでやっていることは間隔、観察を取るとのforkJoinのための各値を交換することであるにサブスクライブすべての操作。次に、同じデータを多数のサブスクリプションに共有するために公開します。

お客様の実装でもう1つ問題があったのは、サブスクリプションを.connect()から返品していたことです。これは、必要なときにいつでも廃棄することを意味しています。オブザーバーは、公開されたソースに登録する必要があります。