Skip to content

Commit ca1cd42

Browse files
committed
fix for loop bug
1 parent 6eef80c commit ca1cd42

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

google-cloud-datastore/src/test/java/com/google/cloud/datastore/it/ITDatastoreTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -144,6 +144,7 @@ private <T> Iterator<T> getStronglyConsistentResults (Query scQuery, Query query
144144
List<T> scResultsCopy = makeResultsCopy(scResults);
145145
Set<T> scResultsSet = new HashSet<>(scResultsCopy);
146146

147+
infiniteloop:
147148
while(true) {
148149
QueryResults<T> results = DATASTORE.run(query);
149150
List<T> resultsCopy = makeResultsCopy(results);
@@ -152,7 +153,7 @@ private <T> Iterator<T> getStronglyConsistentResults (Query scQuery, Query query
152153
}
153154
for (T res: resultsCopy) {
154155
if (! scResultsSet.contains(res)) {
155-
continue;
156+
continue infiniteloop;
156157
}
157158
}
158159
return resultsCopy.iterator();

0 commit comments

Comments
 (0)