run_tasks_forever

Function run_tasks_forever 

Source
pub async fn run_tasks_forever<F>(
    tasks: Vec<CronTask>,
    max_parallelism: usize,
    shutdown: F,
)
where F: Future<Output = ()>,
Expand description

Runs a collection of CronTasks until shutdown fires.

When shutdown completes, the loop stops scheduling new tasks and drains any currently running tasks before returning.