RXJS 5-当所有源发出时，从可观察到的数组中发出一个组合值。

Question

我使用可观测的pipe方法合成多个可观测值，当数组中的所有可观测值发出时，我想发出一个最终的复合值。

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}]
  })
})

...but --我正在寻找一种不用嵌套subscribe调用就能在pipe链中完成它的方法。

zip运算符在某种程度上是可行的，但它似乎不适用于可观察到的数组。是否有一个像forkJoin一样工作并且可以与pipe一起使用的可访问运算符？

Answer 1

你们很亲密。您希望返回链中可观察到的forkJoined，并等待它与concatMap一起发布(mergeMap在这里也会工作)。

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