Normalize timeout error when receiving pipeline results

#1748 (comment)
jackc · Sep 30, 2023 · 163eb68 · 163eb68
1 parent a61517a
commit 163eb68
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pgconn/pgconn.go b/pgconn/pgconn.go
@@ -1996,7 +1996,8 @@ func (p *Pipeline) GetResults() (results any, err error) {
 	for {
 		msg, err := p.conn.receiveMessage()
 		if err != nil {
-			return nil, err
+			p.conn.asyncClose()
+			return nil, normalizeTimeoutError(p.ctx, err)
 		}
 
 		switch msg := msg.(type) {