Restart signalMessage when receiving non-error message in CopyFrom

fixes #21
2019-12-21 10:06:24 -06:00
parent bd0ce203e9
commit dd53b7488d
1 changed files with 2 additions and 0 deletions
@@ -1022,6 +1022,8 @@ func (pgConn *PgConn) CopyFrom(ctx context.Context, r io.Reader, sql string) (Co
 			switch msg := msg.(type) {
 			case *pgproto3.ErrorResponse:
 				pgErr = ErrorResponseToPgError(msg)
+			default:
+				signalMessageChan = pgConn.signalMessage()
 			}
 		default:
 		}