在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));
