如何发出 Observable 然后限制订阅答案

【问题标题】：How to emit an Observable and then throttle the subscription如何发出 Observable 然后限制订阅
【发布时间】：2019-01-28 05:06:22
【问题描述】：

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

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

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

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

【问题讨论】：

leading 和 trailing 选项可能是您正在寻找的：github.com/ReactiveX/rxjs/blob/6.3.3/spec/operators/…
试试throttle()
@cartant 你的建议很完美。如果您将其写为答案，我会将其标记为正确。谢谢。
@ebakunin 如果您能够使用该建议来解决您的问题，也许您可以写一个self answer？我没有时间写一个自动取款机。

标签： angular rxjs rxjs6 rxjs-pipeable-operators

【解决方案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));

【讨论】：

不幸的是，由于 delay 失败的相同原因，这将不起作用：该操作将在 3 秒后发生，而不是等待 3 秒后发生。

【解决方案2】：

这应该可以在tap()中进行操作

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

【讨论】：