Function kube_runtime::scheduler::scheduler

pub fn scheduler<T: Eq + Hash + Clone, S: Stream<Item = ScheduleRequest<T>>>(
    requests: S
) -> Scheduler<T, S>

Stream transformer that delays and deduplicates [Stream] items.

Items are deduplicated: if an item is submitted multiple times before being emitted then it will only be emitted at the earliest Instant.

Items can be “held pending” if the item doesn’t match some predicate. Items trying to schedule an item that is already pending will be discarded (since it is already going to be emitted as soon as the consumer is ready for it).