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

threadedstream · web-flow · commit 94c6b194d7ca · 2024-03-18T17:53:14.000+01:00
* make errors chan buffered

* remove unnecessary select in the beginning of acquire

* undo the actions of previous commit
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)
 	)
 

Original file line number	Diff line number	Diff line change
`@@ -65,7 +65,7 @@ func (c connect) query(ctx context.Context, release func(connect, error), quer`
`65`	`65`	`bufferSize = options.blockBufferSize`
`66`	`66`	`}`
`67`	`67`	`var (`
`68`		`- errors = make(chan error)`
	`68`	`+ errors = make(chan error, 1)`
`69`	`69`	`stream = make(chan *proto.Block, bufferSize)`
`70`	`70`	`)`
`71`	`71`