Module scheduler

Source
Expand description

Delays and deduplicates Stream items

Structs§

Hold
See Scheduler::hold
HoldUnless
See Scheduler::hold_unless
ScheduleRequest
A request to re-emit message at a given Instant (run_at).
Scheduler

Functions§

debounced_scheduler
Stream transformer that delays and deduplicates Stream items.
scheduler
Stream transformer that delays and deduplicates items.