eliminate readQueue stuck channel on relay close.

2026-03-14 05:53:16 -03:00
parent 6cbe984e16
commit 2cec1c9434
1 changed files with 5 additions and 1 deletions
@@ -316,7 +316,11 @@ func (r *Relay) newConnection(ctx context.Context, httpClient *http.Client) erro
 			}

 			msg := string(buf.Bytes())
-			readQueue <- msg
+			select {
+			case readQueue <- msg:
+			case <-connCtx.Done():
+				return
+			}
 		}
 	}()