如何停止去抖动的Rxjs Observable？

debugcn 发表于 Dev

演员

我创建了一个可观察对象，它将在最后一次更改后3秒触发，并调用publishChange该服务的。它可以工作，但是我想创建一个doImmediateChange函数，该函数publishChange立即调用并停止可观察到的去抖动。那怎么可能？

我的组件：

class MyComponent {
    private updateSubject = new Subject<string>();

    ngOnInit() {
        this.updateSubject.pipe(
            debounceTime(3000),
            distinctUntilChanged()
        ).subscribe(val => {
            this.srv.publishChange(val);
        });
    }

    doChange(val: string) {
        this.updateSubject.next(val);
    }

    doImmediateChange(val: string) {

        // Stop the current updateSubject if debounce is in progress and call publish immediately
        // ??
        this.srv.publishChange(val);

    }

}

理查德·邓恩

使用竞赛运算符：

完成的第一个可观察变量将成为唯一的可观察变量，因此此递归函数将在发出一次后完成take(1)，然后重新订阅() => this.raceRecursive()。

private timed$ = new Subject<string>();
private event$ = new Subject<string>();

ngOnInit() {
  this.raceRecursive()
}

raceRecursive() {
  race(
    this.timed$.pipe(debounceTime(1000)),
    this.event$
  )
    .pipe(take(1)) // force it to complete
    .subscribe(
      val => console.log(val), // srv call here
      err => console.error(err),
      () => this.raceRecursive() // reset it once complete
    )
}

doChange(val: string) {
  this.timed$.next(val)
}

doImmediateChange(val: string) {
  this.event$.next(val)
}

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。