pub fn debounced_scheduler<T: Eq + Hash + Clone, S: Stream<Item = ScheduleRequest<T>>>(
requests: S,
debounce: Duration,
) -> Scheduler<T, S>
Expand description
Stream transformer that delays and deduplicates Stream
items.
The debounce period lets the scheduler deduplicate requests that ask to be emitted instantly, by making sure we wait for the configured period of time to receive an uninterrupted request before actually emitting it.
For more info, see scheduler()
.