make_looper

Function make_looper 

Source
pub fn make_looper<Fut1, Fut2>(
    pg_pool: Pool,
    redis_pool: Pool,
    token: CancellationToken,
    schedule: Schedule,
    stop_check_duration: Duration,
    task_function: impl Fn(DateTime<Utc>, Result<Client, PoolError>, Result<Connection, PoolError>, CancellationToken) -> Fut1 + Send + Sync + 'static,
    stop_function: impl Fn(Result<Client, PoolError>, Result<Connection, PoolError>) -> Fut2 + Send + Sync + 'static,
) -> JoinHandle<()>
where Fut1: Future<Output = LoopState> + Send, Fut2: Future<Output = ()> + Send,