Searched refs:runtime_spawn (Results 1 – 9 of 9) sorted by relevance
22 use crate::utils::runtime_spawn;86 runtime_spawn(unload_sa(tx)) in count_down()
40 use crate::utils::runtime_spawn;92 let join_handle = runtime_spawn(async move { in try_restart()220 let join_handle = runtime_spawn(async move { in reschedule_inner()
42 use crate::utils::runtime_spawn;115 runtime_spawn(restore_all_tasks(tx.clone())); in init()117 runtime_spawn(clear_timeout_tasks(tx.clone())); in init()118 runtime_spawn(log_all_task_info(tx.clone())); in init()119 runtime_spawn(task_manager.run()); in init()
22 use crate::utils::runtime_spawn;46 runtime_spawn(AccountUpdater::new(task_manager).update()); in update_accounts()
19 use crate::utils::runtime_spawn;31 runtime_spawn(run(info.clone())); in init()
25 use crate::utils::runtime_spawn;88 runtime_spawn(run_count_manager.run()); in init()
25 use crate::utils::runtime_spawn;68 runtime_spawn(client_manager.run()); in init()
28 use crate::utils::{runtime_spawn, Recv};166 runtime_spawn(client.run()); in constructor()
96 pub(crate) fn runtime_spawn<F: Future<Output = ()> + Send + Sync + 'static>( in runtime_spawn() function