Async Tasks

[andre-di]

Hi, I am trying to use AsyncScheduler within my project and I was just wondering if there were any better or more ergonomic ways of doing this? I struggled a lot getting the state shared, but somehow got that working. Any tips or tricks greatly appreciated.

pub async fn scheduler_init(state: Arc<State>) {
    let mut scheduler = AsyncScheduler::new();

    // Refactor these blocks into add function
    let shared_state = Arc::clone(&state);
    scheduler.every(60.seconds()).run(move || {
        let shared_state = Arc::clone(&shared_state);
        async move {
            test_task(&shared_state).await
        }
    });
    // endblock

    // Refactor these blocks into add function
    let shared_state = Arc::clone(&state);
    scheduler.every(60.seconds()).run(move || {
        let shared_state = Arc::clone(&shared_state);
        async move {
            test_task_two(&shared_state).await
        }
    });
    // endblock
}

async fn test_task_two(state: &Arc<State>)  {
    // do something
}

async fn test_task(state: &Arc<State>) {
    // do something
}

Thank you