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 takes a message and Instant (in the form of a ScheduleRequest), and emits the message at the specified Instant.

Objects are de-duplicated: if a message is submitted twice before being emitted then it will only be emitted at the earlier of the two Instants.