从源镜像至多 1 个值，然后暂时删除值，直到另一个 observable 发出

Question

我想以

这样的方式组合两个可观察对象

我最多镜像 1 个来自源可观察值的值（它到达的同一时刻），
然后忽略它的后续值，直到 notifier observable 发出；
然后，我允许从源镜像最多 1 个值；
之后我再次忽略元素，直到通知器 observable 发出
等等

来源：

a----a----a----a----a----a Source
------------b---------b--- Notifier
a--------------a---------a Desired result

可观测值是无限的。

你能推荐一个实现这个的方法吗？

Answer 1

我相信这是 throttle() 运算符的一个简单用例。

// TypeScript
let source$: Observable<any>;
let notifier$: Observable<any>;
let result$: Observable<any>;

result$ = source$.pipe(
  throttle(_=>notifier$)
);

参考Link：https://www.learnrxjs.io/learn-rxjs/operators/filtering/throttle

从源镜像至多 1 个值，然后暂时删除值，直到另一个 observable 发出

Mirror at most 1 value from source, then temporarily drop values until another observable emits

rxjs

reactive-programming