Angular 8 和链式 observables

Question

我有一个组件 X，它需要订阅多个 observables 的结果，然后将此结果发送给组件 Y。 这些是必须以某种方式联合起来才能产生我需要的结果的可观察对象：

1. getChosenCityId (behaviourSubject) // 一旦我有了 id，我就可以像这样得到城市：
2. getCityById(id)（http 调用的结果）

// 一旦我有了城市，这是一个对象，我需要它的属性——cityLocation

4. getCitiesByLocation(cityLocation)（http 调用的结果）//来自上一行的 cityLocation
5. 获取NearbyCities。 (behaviorSubject) 返回一个布尔值。如果是真的，我需要

一）

• citiesByLocation (4.)
• chosenCityId (1.)

如果是假的，我需要：

b)

• 城市 (2.)
• chosenCityId(1.)

a) 和 b) 是我需要发送到组件 Y 的结果（带有下一个）。如何链接所有这些可观察对象？

Answer 1

使用更高级别的地图运算符，例如 switchmap：

nearbyCities$ = getChosenCityId.pipe(
  switchMap(id => getCityById(id)),
  switchMap(city => getCitiesByLocation(city.location)),
);

Answer 2

有点难以解释，但有点像......

this.getChosenCityId.pipe( // get id
  switchMap(id => this.getCityById(id)), // fetch the city
  withLatestFrom(this.getNearbyCities), // with the latest from get nearby
  switchMap(([city, getNearby]) => 
    getNearby // if get nearby, then get cities by location and map
      ? this.getCitiesByLocation(city.location).pipe(map(nearbyCities => ({city, nearbyCities})))
      : of({city}) // else just return the city
  )
).subscribe(result => console.log(result))

如果您还想在getNearbyCities 更改时自动更新，则设置会有所不同：

combineLatest(this.getChosenCityId, this.getNearbyCities).pipe( // run when either emits
  switchMap(([id, getNearby]) => 
    this.getCityById(id).pipe(
      switchMap(city => 
        getNearby 
          ? this.getCitiesByLocation(city.location).pipe(map(nearbyCities => ({city, nearbyCities})))
          : of({city})
      )
    )
  )
).subscribe(result => console.log(result))