Potentially fix infinite loop

Astralchroma · Astralchroma · commit dec282bec032 · 2025-08-18T18:49:50.000+01:00
diff --git a/.vscode/settings.json b/.vscode/settings.json
@@ -0,0 +1,5 @@
+{
+    "rust-analyzer.server.extraEnv": {
+        "SQLX_OFFLINE": "true"
+    }
+}
diff --git a/src/gateway.rs b/src/gateway.rs
@@ -124,9 +124,9 @@ async fn gateway_accept(
 				pending_pong = None;
 			}
 			socket_message = receiver.recv() => {
-				if let Some(socket_message) = socket_message {
-					socket.send(Message::Text(socket_message.into())).await?;
-
+				match socket_message {
+					Some(socket_message) => socket.send(Message::Text(socket_message.into())).await?,
+					None => return Err(Closed),
 				}
 			}
 			_ = &mut keep_alive => {

-Original file line number
+Diff line change
@@ @@ -0,0 +1,5 @@ @@
 +{
 +    "rust-analyzer.server.extraEnv": {
 +        "SQLX_OFFLINE": "true"
 +    }
 +}
Original file line number	Diff line number	Diff line change
`@@ -124,9 +124,9 @@ async fn gateway_accept(`
`124`	`124`	`pending_pong = None;`
`125`	`125`	`}`
`126`	`126`	`socket_message = receiver.recv() => {`
`127`		`- if let Some(socket_message) = socket_message {`
`128`		`- socket.send(Message::Text(socket_message.into())).await?;`
`129`		`-`
	`127`	`+ match socket_message {`
	`128`	`+ Some(socket_message) => socket.send(Message::Text(socket_message.into())).await?,`
	`129`	`+ None => return Err(Closed),`
`130`	`130`	`}`
`131`	`131`	`}`
`132`	`132`	`_ = &mut keep_alive => {`