angular – RxJS：debounceTime返回所有值

发布时间：2020-12-17 17:36:17 所属栏目：安全来源：网络整理

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

如果没有其他事件发生,是否可以延迟运行序列,并立即返回所有值？

我需要某种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(...)

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!