Module scheduler

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.