RxJs

Question

在 RxJx 中，我正在尝试更新“Observable”，但它没有更新值。我一直在获取第一个声明值。

如何解决这个问题？

这是我的代码：

 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$ 中（在这种情况下，您需要它是某种主题）。

RxJs - 不更新 `Observable` 打印所有相同的结果

RxJs - Not updating the `Observable` prints allwasy same result