wsio_core/utils/
task.rs

1use tokio::{
2    sync::Mutex,
3    task::JoinHandle,
4};
5
6pub async fn abort_locked_task(task: &Mutex<Option<JoinHandle<()>>>) {
7    if let Some(task) = task.lock().await.take() {
8        task.abort();
9    }
10}