diff --git a/src/websocket.rs b/src/websocket.rs index 2310e0f..55e82f5 100644 --- a/src/websocket.rs +++ b/src/websocket.rs @@ -105,11 +105,13 @@ pub async fn send_to_ipbl_websocket( Ok(_) => {} Err(e) => { println!("err send read: {e:?}"); - return handle_websocket_error(ws); + ws.close(None).unwrap_or(()); + return false; } }; } else { - return handle_websocket_error(ws); + ws.close(None).unwrap_or(()); + return false; }; if ws.can_read() { @@ -117,19 +119,13 @@ pub async fn send_to_ipbl_websocket( Ok(_) => {} Err(e) => { println!("err send read: {e:?}"); - return handle_websocket_error(ws); + ws.close(None).unwrap_or(()); + return false; } }; } else { - return handle_websocket_error(ws); + ws.close(None).unwrap_or(()); + return false; }; true } - -fn handle_websocket_error(ws: &mut WebSocket>) -> bool { - match ws.close(None) { - Ok(o) => {} - Err(e) => {} - }; - return false; -}