dstream

DelayedStream - wraps any stream with items as (Key, Value) (or more generally anything implementing KeyValue trait). Output is delayed by at least delay value - if in meanwhile new item comes with same Key, old one is dropped and new one is waiting delay again.

Use case is when there are similar items (same Key) coming sequentially in short intervals past further only latest one, or one when interval to previous one gets larger then delay.