Ionic2 中的多个 $http 请求间隔

Question

我想将多个 http 请求分叉到一个 observable 中，按时间间隔调用它并在所有订阅者之间共享相同的数据。

到目前为止，我的代码如下所示：

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

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();

然后 Observers 订阅这个 observable

source.subscribe(...);

我在这里做的是获取可观察的间隔并替换所有操作的 forkJoin 的每个值。然后发布它以将相同的数据共享给许多订阅。

您在实施中遇到的另一个问题是您从 .connect() 返回订阅，这只是为了在您需要时处理它（取消订阅）。观察员应订阅已发布的来源。

Ionic2 中的多个 $http 请求间隔

Multiple $http requests in Ionic2 with interval

http

intervals

observable

ionic2