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

Question

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

就我而言，我在 Angular 工作。例如，这段代码:

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

不会完成我需要的，因为发射发生在持续时间结束时。我需要相反的东西:发射发生然后延迟。我怎样才能做到这一点？

Answer 1

使用经典的超时函数怎么样？

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