RxJs -没有更新“观察者”打印结果都是相同的

Question

在RxJx中，我试图更新“观察者”，但它没有更新值。我一直在获取第一个声明的值。

怎么解决这个问题？

这是我的代码：

 const streamA$ = Rx.Observable.of(2);
  const streamB$ = Rx.Observable.of(4);

 streamA$ = Rx.Observable.of(10) //not updating!

  const streamC$ = Rx.Observable.concat(streamA$, streamB$)
  .reduce((x, y) => x  + y);



streamC$.subscribe(function(x){
  console.log( x );
}); //prints 6

//even from here i would like to update
    streamA$ = Rx.Observable.of(10) //not updating!

Answer 1

您已经使用const声明了streamA$，然后尝试重新分配它。这样做将导致原始值被保留。如果要重新分配streamA$，则需要使用var声明它。对于所有的javascript变量，这都是正确的，而不是Rx特有的。

我怀疑您实际上想要做的是将streamA$与另一个流结合起来，或者直接将一个值输入streamA$ (在这种情况下，您将需要它成为某种主题)。