angular – RxJS：debounceTime返回所有值

解决方法@H_607_10@

如果我理解正确,您需要一个缓冲事件的运算符,直到某段时间没有事件发生,然后重复所有缓冲的事件.我会试试这个：

将此新运算符设置为Observable原型：

function bufferedDebounCETime(timE) {
    return Observable.create(subscriber => {
        let buffer = [];
        return this.do(x => buffer.push(X))
            .debounCETime(timE)
            .flatMap(() => buffer)
            .do(() => buffer = [])
            .subscribe(
                value => subscriber.next(value),err => subscriber.error(err),() => subscriber.complete()
            );
    });
}

Observable.prototype.bufferedDebounCETime = bufferedDebounCETime;

然后将其用作运算符：

yoursourceObservable.bufferedDebounCETime(1000).subscribe(...)