infinite scan fixed. #885

pull/903/head
Nikita 8 years ago
parent 946f712931
commit 4f5044995c

@ -101,6 +101,7 @@ abstract class RedissonBaseIterator<V> implements Iterator<V> {
currentElementRemoved = false; currentElementRemoved = false;
removeExecuted = false; removeExecuted = false;
client = null; client = null;
firstValues = null; firstValues = null;
lastValues = null; lastValues = null;
@ -111,6 +112,19 @@ abstract class RedissonBaseIterator<V> implements Iterator<V> {
} }
finished = true; finished = true;
return false; return false;
} else if (!firstValues.isEmpty()) {
if (res.getPos() == 0) {
if (tryAgain()) {
client = null;
firstValues = null;
nextIterPos = 0;
prevIterPos = -1;
continue;
}
finished = true;
return false;
}
} }
} }
lastIter = res.getValues().iterator(); lastIter = res.getValues().iterator();

Loading…
Cancel
Save