diff --git a/pgconn/pgconn.go b/pgconn/pgconn.go index 8f602e40..b4baeb14 100644 --- 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) {