Function kube::runtime::scheduler

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

This is supported on crate feature runtime only.

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).

The Scheduler terminates as soon as requests does.