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 schedules each item to be performed at a given time.