可以使用RxJS中的 throttleTime 操作符来实现节流功能。将需要节流的方法包装在一个 Subject 中,并通过 Subject 的 next 方法来触发调用。然后使用 throttleTime 操作符来限制方法的调用次数。
代码示例:
在组件中定义一个 Subject:
import { Subject } from 'rxjs';
@Component({
selector: 'app-example',
template: `Some text`
})
export class ExampleComponent implements OnInit {
private subject = new Subject();
constructor() { }
ngOnInit(): void {
this.subject.pipe(
throttleTime(5000) // 限制方法每五秒调用一次
).subscribe(() => {
this.doSomething();
});
}
methodCalled(): boolean {
this.subject.next();
return true; // 返回true来确保class.something被添加到DOM
}
doSomething(): void {
// 需要节流的方法
}
}
在模板中使用 class-binding 来触发 Subject 中的方法,并返回 true 来确保 class.something 添加到 DOM 元素中。在 ngOnInit 生命周期钩子函数中,通过 throttleTime 操作符对 Subject 进行节流,并在 subscribe 回调中调用实际的需要节流的方法。