时间戳

首页 > 解决方案 > 为什么 rxjs debounceTime 不适用于使用“of”运算符创建的可观察对象？

angular - 为什么 rxjs debounceTime 不适用于使用“of”运算符创建的可观察对象？

问题描述

使用angular 7和rxjs 6：

<input (input)="onChange($event.target.value)">

为什么以下不去抖动？

onChange(val: string) {
  of(val)
    .pipe(        
      debounceTime(300)        
  ).subscribe(valx => {
    console.log(valx);
  });
}

但这确实：

  searchTerm$: Subject<string> = new Subject();

  this.searchTerm$.pipe(      
    debounceTime(300),    
  ).subscribe(val => {
   console.log(val);
  });


onChange(val: string) {   
  this.searchTerm$.next(val);
}

标签： angularrxjsrxjs6debouncing

解决方案

这不是因为of()。在您的第一个示例中，每次调用时，onChange($event.target.value)您都在创建一个具有自己debounceTime和自己的计时器的新链。所以它永远不会去抖动任何东西，因为每个输入更改都有自己的链。

但是，如果您使用Subject（如在第二个示例中）并推送所有事件，this.searchTerm$.next(val)那么您只有一个链，其中每个事件都被推送到顶部，然后按照您的预期去抖动。

推荐阅读