dstream

DelayedStream - 将任何带有项目作为 (键，值)（或更一般地，任何实现 KeyValue 特性的东西）的流包装起来。输出至少延迟 delay 值 - 如果在此期间有新的项目带有相同的键，则丢弃旧的项目，新的项目再次等待延迟。

用例是在短时间内有类似的项目（相同的键）依次到来，只保留最新的一个，或者当一个项目与前一个项目的间隔大于延迟时。