RxJS Angular：听一个可观测值并使用另两个的最新值

Question

我使用Redux和RxJS Angular（4）实现来管理状态

我正在监听一个事件（产品列表中选定产品ID的更改），所以我们称之为selectedproductId$。

当相关发射器发出一个新的selectedId值时，我想从这个可观察值中执行一个开关映射，以及从另外两个可观察值中发出的最新值（比如；productDetails$和productComments$）。

因此，触发更改应该是selectedproductID，我们将使用product详细信息和product注释的最新值执行SwitchMap。

我试过这个：

// subscribed to the 3 observable passed in combineLatest
 fetchProduct$: Observable<any>;
 this.fetchProduct$ = Observable.combineLatest(
       this.selectedProductId$,
       this.productComments$,
       this.productDetails$
 ).switchMap(
       result => Observable.of(
         {
           'uuid': result[0],
           'comments': result[1],
           'details': result[2]
         }
      )
 );

然后我订阅这个可观察的，并在传递的值上放置一个断点：

this.fetchProductSubscription = this.fetchProduct$.subscribe(result => this.someFn(value));

它可以工作，但每次三个观测值中的一个检测到状态变化时，它都会被调用。我也试着观察。forkJoin，但是从doc中，它等待三个可观察对象发出新的值，这使我在从另一个web服务获取评论时处于一种奇怪的状态，并且它可以在选择下一个产品Id时检索它。

可见的。合并也不是解决方案，因为它只会在一个“通道”上逐个发出值。

我不完全习惯于反应式编程，也许我没有清楚地看到一个明显的解决方案，但正确的知道我会喜欢一个提示或一些帮助来解决这个问题：（非常感谢

Answer 1

首先，让我们合并您不想触发任何更改的“额外”观测值。

const extras$ = Observable.combineLatest(this.productComments$, this.productDetails$);

现在，我们在我们的“有趣的”可观察范围内观察排放，并且只使用我们额外的最新值。

cosnt allTogether$ = this.selectedProductId$.withLatestFrom(extras$,
    ([uuid, [comments, details]]) => ({uuid, comments, details}) );

现在，您可以免费订阅all在一起$。

Answer 2

请尝试使用LatestFrom，它的工作原理类似于CombineTest（），但每次激发源可观察对象时都会激发。示例（对于rxjs 5.5）：

this.fetchProduct$ = 
  this.selectedProductId$.pipe(
   withLatestFrom(
       this.productComments$,
       this.productDetails$
   ));

或对于早期版本：

this.fetchProduct$ = 
  this.selectedProductId$.withLatestFrom(
       this.productComments$,
       this.productDetails$
   );