make errors chan buffered

threadedstream · threadedstream · commit 2fc5dd8ab356 · 2024-03-18T17:31:57.000+03:00
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`