Angular 和 Observable debounceTime

Question

在 Angular 4 项目中，我有一个函数(我们称之为 reload())，它可以被其他函数调用(我们称之为 A() )并且B()) 随时。我想对 reload() 的执行进行反跳，直到从最后一次调用 A() 或 B()< 过去 X 时间(即毫秒)/。我正在查看 Rx.Observable.debounce 和 Rx.Observable.debounceTime 函数，但我不明白它们是否真的可以帮助我。

一个例子:

time 0ms: A() gets executed and it calls reload()
time 200ms: B() calls executed and it calls reload()
Since X is set to 500ms, reload() should be called only once and after 500ms.

Answer 1

您可以将Subject与debounceTime结合使用。因此，让 A 和 B 两个函数都向主题发送一个值。然后对主题流进行反跳，以便在经过 x 时间后仅发出值。

// component.ts
subject$ = new Subject();
stream$;

constructor(){
    this.stream$ = this.subject$.debounceTime(1000);
}

A(){
    this.subject$.next('some value');
}
B(){
    this.subject$.next('some value');
}

ngOnInit(){
    this.stream$.subscribe(res => {
        this.reload();
    });
}

这是一个stack blitz演示这个。