angular – 如何发出Observable然后限制订阅

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

导读：在RxJS中,auditTime和throttleTime等过滤器在经过一定时间后会发出一个Observable(以不同的方式).我需要发出一个Observable,然后在发出下一个值之前等待一段时间. 就我而言,我在Angular工作.例如,这段代码： this.fooService$.pipe(throttleTime(10000)).sub

在RxJS中,auditTime和throttleTime等过滤器在经过一定时间后会发出一个Observable(以不同的方式).我需要发出一个Observable,然后在发出下一个值之前等待一段时间.

就我而言,我在Angular工作.例如,这段代码：

this.fooService$.pipe(throttleTime(10000)).subscribe(() => this.doSomething());

不能完成我需要的东西,因为排放发生在持续时间结束时.我需要相反：发射然后延迟.我怎么能做到这一点？

解决方法

那么使用经典的超时功能怎么样？

this.fooService$.subscribe( () =>
    setTimeout(() => { this.doSomething(); },3000)
);

编辑：

请参阅您的评论,在您的发射方面执行以下操作(仅作为示例)：

// RxJS v6+
import { timer,BehaviorSubject } from 'rxjs';

// timer starts with a delay of 1000 ms and then emits every 2000 ms
const source = timer(1000,2000);
const emitter: BehaviorSubject<number> = new BehaviorSubject(-1);

const subscribe = source.subscribe( value => this.emitter.next(value));

（编辑：李大同）

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