diff --git a/pgconn.go b/pgconn.go
index 210d9979..4c75d367 100644
--- a/pgconn.go
+++ b/pgconn.go
@@ -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:
 		}