diff --git a/src/client.rs b/src/client.rs index f2ee3d4..6ee3ceb 100644 --- a/src/client.rs +++ b/src/client.rs @@ -51,7 +51,7 @@ pub async fn client_mode(client_config: ClientConfiguration, fd: i32, close_toke let mut buf = vec![0; 1400]; // mtu loop { tokio::select! { - _ = subtasks_quit.lock().cancelled() => { + _ = subtasks_quit.lock().unwrap().cancelled() => { info!("Cancellation token has been thrown dev_read_task"); return; } @@ -74,7 +74,7 @@ pub async fn client_mode(client_config: ClientConfiguration, fd: i32, close_toke loop { tokio::select! { - _ = subtasks_quit.lock().cancelled() => { + _ = subtasks_quit.lock().unwrap().cancelled() => { info!("Cancellation token has been thrown sock_read_task"); return; }