Make errors channel buffered inside query() (#1237)

* make errors chan buffered * remove unnecessary select in the beginning of acquire * undo the actions of previous commit
ClickHouse · Mar 18, 2024 · 94c6b19 · 94c6b19
1 parent 9491310
commit 94c6b19
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/conn_query.go b/conn_query.go
@@ -65,7 +65,7 @@ func (c *connect) query(ctx context.Context, release func(*connect, error), quer
 		bufferSize = options.blockBufferSize
 	}
 	var (
-		errors = make(chan error)
+		errors = make(chan error, 1)
 		stream = make(chan *proto.Block, bufferSize)
 	)