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

Answer 2

这应该在tap()

this.fooService$.pipe(
tap(() => this.doSomething()),
switchMap(()=>timer(10000))
)
.subscribe();