我希望实现一种情境,当连续的事件源(例如拖动元素)上发生某些事情时,加入一些缓冲/节流机制。我希望接收通知,例如:
- 每400毫秒
- 但仅在事件源中有新项目(实际发生了拖动)时
Rx.Observable
.fromEvent(element, "drag")
.throttle(400);
我猜需要一个计时器源,但在这种情况下,如何将计时器源和拖动源与上述标准相结合?