Skip to main content

select_due_scheduled_times

flow::batching_mode::eval_schedule

Function select_due_scheduled_times 

Source 
pub fn select_due_scheduled_times(
    schedule: &EvalSchedule,
    cursor_secs: i64,
    wall_now_secs: i64,
) -> Option<DueScheduledTimes>
Expand description

Select due scheduled times <= wall_now_secs without materializing all missed ticks.