Function kube_runtime::scheduler::scheduler

pub fn scheduler<T: Eq + Hash + Clone>(
    requests: impl Stream<Item = ScheduleRequest<T>>
) -> impl Stream<Item = Result<T>>

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.