如果没有其他事件发生,是否可以延迟运行序列,并立即返回所有值？
我需要某种debounceTime函数,但这将返回所有值.
解决方法
如果我理解正确,您需要一个缓冲事件的运算符,直到某段时间没有事件发生,然后重复所有缓冲的事件.我会试试这个：
将此新运算符设置为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(...)
