diff --git a/pgconn.go b/pgconn.go index e51d40e8..5d84871b 100644 --- a/pgconn.go +++ b/pgconn.go @@ -361,6 +361,9 @@ func (pgConn *PgConn) ReceiveMessage(ctx context.Context) (pgproto3.BackendMessa defer pgConn.contextWatcher.Unwatch() msg, err := pgConn.receiveMessage() + if err != nil { + err = linkErrors(ctx.Err(), err) + } return msg, err }