From 5a0b18e65abec5d0d8ea31323ec1ff15faeac30e Mon Sep 17 00:00:00 2001
From: fiatjaf <fiatjaf@gmail.com>
Date: Thu, 12 Mar 2026 17:14:18 -0300
Subject: [PATCH] add buffers to read and write queues.

---
 relay.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/relay.go b/relay.go
index b75eef0..06fda9e 100644
--- a/relay.go
+++ b/relay.go
@@ -254,10 +254,10 @@ func (r *Relay) newConnection(ctx context.Context, httpClient *http.Client) erro
 	ticker := time.NewTicker(19 * time.Second)
 
 	// main websocket loop
-	readQueue := make(chan string)
+	readQueue := make(chan string, 64 /* add some buffer to account for processing/IO mismatches */)
 
 	r.conn = c
-	r.writeQueue = make(chan writeRequest)
+	r.writeQueue = make(chan writeRequest, 64 /* idem */)
 	r.closed = &atomic.Bool{}
 	r.closedNotify = make(chan struct{})