我如何增加a＆lt;数字＆gt;重录的价值？

Question

我正在使用chativioursubject，但我发现很难增加或减少

我要么创建一个无限循环的数字：

this.observer.pointsCollected$.subscribe(val => this.observer.pointsCollected$.next(val + 10));

或者我只使用一个更新，使用：

this.observer.pointsCollected$.pipe(take(1)).subscribe(val => this.observer.pointsCollected$.next(val + 10));

使用：

public pointsCollected$ = new ReplaySubject<number>();

我想 我已经使用actavionursubject并使用actabioUrsubject.getValue（）解决了这个问题，

请告诉我是否这是一种好方法

Answer 1

清楚定义所需的行为很重要。一个replaySubject（从可观察的意义上中）没有值，它只是一个向其订户散发值的对象。

说“ 增加一个replayubject 的值”还不够精确。

也许您想“ 发射先前发射的值增加了特定的数量”

这听起来像是

要设置该设置，我们可以拥有一个发出要添加的“增量”的主题，并得出一个可观察到的发出计算值的可观察值：

increment$ = new BehaviorSubject<number>(DEFAULT_NUMBER);
  
number$ = increment$.pipe(
  scan((previous, increment) => previous + increment)
);

我们现在可以订阅number $并最初接收默认值。任何时候增量$ .next（）被调用，号码$将发出上一个发行和新增量的总和。

在Angular中，您可以将其包裹在服务中，并提供公开方法来增加数字：

export class NumberService {

  private increment$ = new BehaviorSubject<number>(DEFAULT_NUMBER);
  
  public number$ = this.increment$.pipe(
    scan((previous, increment) => previous + increment)
  );

  public increaseNumber(amount: number) {
    this.increment$.next(amount);
  }

}

这是一个工作 stackblitz 演示。

Answer 2

console.clear();
import { ReplaySubject } from 'rxjs';

const sub = new ReplaySubject(3);
let inc:any=0;
sub.next(1);
sub.next(9);
sub.subscribe((res) => {
  inc = inc + res;
});
console.log(inc);

• 其他人则认为使用循环＆amp;＆amp; 递归功能。

Answer 3

第一种方法是错误的，因为正如您所说，这是一个无限的循环。

我认为第二个是“增加重型对象的值”的最佳方法：它仅获得1个单个值（当前），然后仅将其递增一次。

如果您想有一个触发的“信号”，您可以将其包裹在一个主题周围：

const performIncrement$ = new Subject<number>();

performIncrement$.pipe(
  withLatestFrom(pointsCollected$),
  map(([increment, v]) => v + increment)
).subscribe(newValue => pointsCollected$.next(newValue))

// Call performIncrement$ every time you want to increment
performIncrement$.next(10)

但是我认为，最好反应地宣布可观察到可观察到，请避免尽可能多地挑战 - 首先是有点挑战 - 而不是思考“发生这种情况时，我需要将点收费的$提高到10”的命令式方式，您需要思考相反的方式”点收费$的价值是发生了多少次乘以10英寸。此示例将变成类似的内容：

const performIncrement$ = new Subject<number>();

const pointsCollected$ = performIncrement$.pipe(
  scan((acc, increment) => acc + increment, 0),
  startWith(0)
);

如果您有多个订户并且想共享相同的值，则可以使用ShareReplay（1）保留最新值 - 类似于ReplaySubject，但无需<代码> .next 它。

理想情况下，您也不会将performincrement $作为主题，这将是另一个可观察到的，只要您应该根据您的逻辑发生这种情况。

Answer 4

我只是这样做了：

x = new BehaviorSubject(1);

increment() {
  this.x.next(this.x.value + 1);
}