From e5a844ecec22c10cc4ee472f531bde6511abe07a Mon Sep 17 00:00:00 2001 From: AsynchronousMatrix Date: Wed, 19 Jul 2023 12:48:54 +0100 Subject: [PATCH] map the response of the `ws.send` call into a LuaError --- packages/lib/src/lua/net/websocket.rs | 28 +++++++++++++-------------- 1 file changed, 14 insertions(+), 14 deletions(-) diff --git a/packages/lib/src/lua/net/websocket.rs b/packages/lib/src/lua/net/websocket.rs index 9380550..c66b93c 100644 --- a/packages/lib/src/lua/net/websocket.rs +++ b/packages/lib/src/lua/net/websocket.rs @@ -154,20 +154,20 @@ where { let mut ws = socket.write_stream.lock().await; - let _ = ws - .send(WsMessage::Close(Some(WsCloseFrame { - code: match code { - Some(code) if (1000..=4999).contains(&code) => WsCloseCode::from(code), - Some(code) => { - return Err(LuaError::RuntimeError(format!( - "Close code must be between 1000 and 4999, got {code}" - ))) - } - None => WsCloseCode::Normal, - }, - reason: "".into(), - }))) - .await; + ws.send(WsMessage::Close(Some(WsCloseFrame { + code: match code { + Some(code) if (1000..=4999).contains(&code) => WsCloseCode::from(code), + Some(code) => { + return Err(LuaError::RuntimeError(format!( + "Close code must be between 1000 and 4999, got {code}" + ))) + } + None => WsCloseCode::Normal, + }, + reason: "".into(), + }))) + .await + .map_err(LuaError::external)?; let res = ws.close(); res.await.map_err(LuaError::external)