1 files changed, 3 insertions, 3 deletions

diff --git a/common/resultset.cpp b/common/resultset.cpp
index 9883f44..b82b14d 100644
--- a/common/resultset.cpp
+++ b/common/resultset.cpp
@@ -98,7 +98,7 @@ void ResultSet::skip(int number)
     }
 }
 
-qint64 ResultSet::replaySet(int offset, int batchSize, const Callback &callback)
+ResultSet::ReplayResult ResultSet::replaySet(int offset, int batchSize, const Callback &callback)
 {
     skip(offset);
     int counter = 0;
@@ -108,10 +108,10 @@ qint64 ResultSet::replaySet(int offset, int batchSize, const Callback &callback)
                 callback(result);
             });
         if (!ret) {
-            break;
+            return {counter, true};
         }
     };
-    return counter;
+    return {counter, false};
 }
 
 QByteArray ResultSet::id()