diff --git a/src/lib.rs b/src/lib.rs index 20b9b47..f908539 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -195,6 +195,8 @@ pub async fn listen_to_ws_task( } } + info!("listen_to_ws_task closing!"); + is_closed.store(true, std::sync::atomic::Ordering::SeqCst); }