RxJS：在另一个可观察对象的事件之后对可观察对象的事件进行采样答案

【问题标题】：RxJS: Sample the events of an observable after the events of another observableRxJS：在另一个可观察对象的事件之后对可观察对象的事件进行采样
【发布时间】：2017-04-11 17:09:14
【问题描述】：

在 RxJS 中，我们有 sample 运算符，根据 the docs：

每当另一个 Observable（通知器）发出时，就从源 Observable 发出最近发出的值。

我想要类似的东西，但是在通知器发出之后发出的值。

带样品：

Stream:   -a---b-c---d--
Notifier: ---x-----x----

Result:   -a-----c------

我想要什么：

Stream:   -a---b-c---d--
Notifier: ---x-----x----

Result:   -----b-----d--

是否有执行此操作的运算符或运算符组合？

【问题讨论】：

试试这样的Notifier.switch(() => Stream.take(1))

标签： javascript rxjs

【解决方案1】：

这里有这个问题的完整答案：Emitting only after set of events?

正如 Yuri 在他的评论中提到的，如果你的Stream 很热，你可以使用Stream.take(1)，如果很冷，请查看上面链接的答案。它使用window 运算符。

【讨论】：