Module kube_runtime::scheduler[−][src]

Expand description

Delays and deduplicates [Stream] items

Structs

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

Stream transformer that delays and deduplicates [Stream] items.