时间戳

首页 > 解决方案 > 更新behaviorsubject中的特定元素，或者只订阅一次

javascript - 更新behaviorsubject中的特定元素，或者只订阅一次

问题描述

我有一个BehaviorSubject每隔 5 秒从我的其他文件中获取持续更新的文件。

但是，有时我不能等待 5 秒才能发生新事件，所以我正在寻找一种方法来仅更新Behaviorsubject.

我创建了以下内容来处理单个元素：

 updateSingleTimer(timer,time,secs = false) {
    this.timers$.pipe(takeUntil(this._destroyed$)).subscribe((data:any) => {
      var newdata = data;
      newdata[timer] = time;
      this.updateTimers(newdata);
    });
  }

当然，这将创建一个无限循环，因为一旦updateTimers调用函数，计时器就会更新。

所以，我只需要在updateSingleTimer函数中获取计时器数据一次，而不是订阅它。

问：我将如何更改上面的代码，这样它只会得到一次结果this.timers$？

问：另外，是否有可能以比我目前所做的更简单的方式更新单个元素？

完整代码：

  _timers = new BehaviorSubject<any>(null);
  private timersChangeSet = new Subject<any>();
  constructor(private http: HttpClient, private router: Router) {
    this.timersChangeSet.subscribe(val => this._timers.next(val))
}

  timers$ = this._timers.asObservable();

updateTimers(object) {
    this.timersChangeSet.next(object);
  }


  updateSingleTimer(timer,time,secs = false) {

// the code will result in infinity loop, of course. but how would i only get the value once?
    this.timers$.pipe(takeUntil(this._destroyed$)).subscribe((data:any) => {
      var newdata = data;
      newdata[timer] = time;
      this.updateTimers(newdata);
    });
  }

标签： javascriptangularrxjsbehaviorsubject

解决方案

就拿1

this.timers$.pipe(take(1), takeUntil(this._destroyed$))

推荐阅读