Fixed next function

takapi327 · Jan 31, 2025 · c611abc · c611abc
1 parent 7addd2c
commit c611abc
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/module/ldbc-connector/shared/src/main/scala/ldbc/connector/ResultSetImpl.scala b/module/ldbc-connector/shared/src/main/scala/ldbc/connector/ResultSetImpl.scala
@@ -41,12 +41,12 @@ private[ldbc] case class ResultSetImpl(
 
   def next(): Boolean =
     if isClosed then raiseError(ResultSetImpl.CLOSED_MESSAGE)
-    else if currentCursor < recordSize then
-      currentRow = Some(records(currentCursor))
-      currentCursor += 1
-      true
+    else if currentCursor <= recordSize then
+      currentRow    = records.lift(currentCursor)
+      currentCursor = currentCursor + 1
+      currentRow.isDefined
     else
-      currentRow = None
+      currentCursor = currentCursor + 1
       false
 
   override def close(): Unit = isClosed = true