diff --git a/bundles/io.github.linkedfactory.core/src/main/scala/io/github/linkedfactory/core/kvin/leveldb/KvinLevelDb.scala b/bundles/io.github.linkedfactory.core/src/main/scala/io/github/linkedfactory/core/kvin/leveldb/KvinLevelDb.scala index d64840b1..8985307d 100644 --- a/bundles/io.github.linkedfactory.core/src/main/scala/io/github/linkedfactory/core/kvin/leveldb/KvinLevelDb.scala +++ b/bundles/io.github.linkedfactory.core/src/main/scala/io/github/linkedfactory/core/kvin/leveldb/KvinLevelDb.scala @@ -400,11 +400,11 @@ class KvinLevelDb(path: File) extends KvinLevelDbBase with Kvin { } override def computeNext: Option[URI] = { - val entry = it.next - val key = entry.getKey var done = false var result: Option[URI] = None while (it.hasNext && !done) { + val entry = it.next + val key = entry.getKey if (key.startsWith(prefix) && count < limit) { val itemId = entry.getValue System.arraycopy(itemId, 0, valuesPrefix, 0, itemId.length)