Try to close the websocket when ending, maybe we weren't closing it nicely, let's see

This commit is contained in:
Mike Dilger 2024-02-19 20:41:25 +13:00
parent 04062b2267
commit e682a3b0e0

View File

@ -346,7 +346,12 @@ impl WebSocketService {
match message_option {
Some(message) => {
let message = message?;
self.handle_websocket_message(message).await?;
if let Err(e) = self.handle_websocket_message(message).await {
if let Err(e) = self.websocket.close(None).await {
log::info!("Err on websocket close: {e}");
}
return Err(e);
}
},
None => break, // the websocket is closed
}