diff --git a/src/transports/ws.rs b/src/transports/ws.rs index 1e6cd19e..bfe74a6b 100644 --- a/src/transports/ws.rs +++ b/src/transports/ws.rs @@ -236,7 +236,9 @@ impl WsServerTask { log::warn!("Unsubscribing from non-existent subscription with id {:?}", id); } } - None => {} + None => { + sender.close().await.expect("Fail to close WS") + } }, res = receiver.next() => match res { Some(Ok(data)) => {