rxjs - RXJS 5 - 当所有源都发出时，从可观察的数组中发出单个复合值

Question

我正在使用 observable 的pipe方法组合多个 observables，并且我想在数组中的所有 observables 发出时发出最终的复合值。

import { apiSvc } from '../lib/api-service'

import { of as observableOf } from 'rxjs/observable/of'
import { map } from 'rxjs/operators'

const uris = [
  '/api/items/1',
  '/api/items/2',
  '/api/items/3'
]

observableOf(uris).pipe(
  // Map uris array to an array of observables.
  map((uris) => calls.map(uri) => apiSvc.get(uri) /* returns observable*/),
  // Perform magic and emit when all calls complete.
  magic()
)
.subscribe((results) => {
  console.log(results) // [{id: 1}, {id: 2}, {id: 3}]
})

我能够做到这一点forkJoin：

import { forkJoin } from 'rxjs/observable/forkJoin'

observableOf(uris).pipe(
  // Map uris array to an array of observables.
  map((uris) => calls.map(uri) => apiSvc.get(uri)),
)
.subscribe((requests) => {
  // Emits when all request observables emit.
  forkJoin(requests).subscribe((results) => {
    console.log(results) // [{id: 1}, {id: 2}, {id: 3}]
  })
})

...但我正在寻找一种方法来在pipe链中完成它而不必嵌套subscribe调用。

该zip运算符有点像在球场上，但它似乎不适用于可观察的数组。是否有一个forkJoin可以使用并且可以与 一起使用的 lettable 运算符pipe？

Answer 1

你非常亲近。您想forkJoin在链中返回 ed Observable 并等待它发出concatMap(mergeMap在这里也可以工作)。

observableOf(uris)
  .pipe(
    // Map uris array to an array of observables.
    concatMap(uris => forkJoin(uris.map(uri => apiSvc.get(uri))),
  )
  .subscribe((responses) => {
    ...
  });