RxJS：在每次返回并行 http 请求时更新客户端

Question

目标：使用 RxJS 并行运行多个异步 http 请求，并在每个请求返回后触发回调。

例如：

getSomeData() {
    Observable.forkJoin(
        this.http.get('/somethingOne.json').map((res:Response) => res.json()),
        this.http.get('/somethingTwo.json').map((res:Response) => res.json())
    ).subscribe(
      data => {
        this.somethingOne = data[0]
        this.somethingTwo = data[1]
      },
      err => console.error(err)
    );
}

上面的代码将并行运行 http.get 请求并将响应映射到 json，但是在每个 http 响应上，我都希望调用我创建的函数。有没有什么方法可以将回调函数传递给传递给 forkJoin 方法的 http 请求？

Answer 1

这行得通吗？只需在当前选择器函数的主体中执行您的函数。 （这里可能有一些语法错误，因为我不使用 ES6）。包括两个版本，具体取决于您希望如何使用该功能，但想法很明确：使用您的 map 选择器功能来运行您想要的任何逻辑。

getSomeData() {
    Observable.forkJoin(
        this.http.get('/somethingOne.json').map((res:Response) => {myFunction(res); return res.json()}),
        this.http.get('/somethingTwo.json').map((res:Response) => myOtherFunction(res.json()))
    ).subscribe(
      data => {
        this.somethingOne = data[0]
        this.somethingTwo = data[1]
      },
      err => console.error(err)
    );
}