角8和链式可观测物体

Question

我有一个组件X，它需要订阅多个观测值的结果，然后将该结果发送给组件Y。这些观测值必须以某种方式联合起来，以产生我需要的结果：

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

//一旦我有了城市，这是一个对象，我需要它的财产-城市定位

a）

• 城市的地理位置
• chosenCityId（1.）

如果是假的，我需要：

（b）

• 城市（2.）
• chosenCityId（1.）

a）和b）是我需要发送到组件Y（接下来）的结果。我怎样才能把所有这些可观察到的东西连锁起来？

Answer 1

这很难解释，但有点像。。。

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

Answer 2

使用更高的贴图操作符，如switchmap：

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