in src/main/java/org/apache/cassandra/distributed/shared/AssertUtils.java [45:59]
public static void assertRows(SimpleQueryResult actual, SimpleQueryResult expected)
{
while (actual.hasNext()) {
if (!expected.hasNext())
throw new AssertionError(rowsNotEqualErrorMessage(actual, expected));
Row next = actual.next();
Row exectedRow = expected.next();
assertTrue(rowsNotEqualErrorMessage(actual, expected),
Arrays.equals(next.toObjectArray(), exectedRow.toObjectArray()));
}
if (expected.hasNext())
throw new AssertionError(rowsNotEqualErrorMessage(actual, expected));
}