RxJS 中的嵌套 http 请求

Question

我是 Angular 的初学者，所以我遇到了挑战。如何使用 RxJS 与 Angular 中的嵌套 http 请求进行交互？

.pipe(
    map((res): Collection => ({
            id: res.id,
            name: res.name,
            description: res.description,
            tracks: res.tracks.items.map(track => this.trackService.fetchTrack(track.id)) //?
        }) 
    ),
)

Answer 1

您需要使用switchMap 从外部可观察对象映射到内部。并且看到您有多个来自数组的 HTTP 调用，您可以使用 forkJoin 并行触发它们。

试试下面的

outerObservable().pipe(
  switchMap((res): Collection => {
    forkJoin(res.tracks.items.map(track => this.trackService.fetchTrack(track.id))).pipe(
      map(tracks => ({
        id: res.id,
        name: res.name,
        description: res.description,
        tracks: tracks
      }))
    )
  })
).subscribe(...)