Simplified replaySet

1 files changed, 16 insertions, 0 deletions

diff --git a/common/resultset.cpp b/common/resultset.cpp
index 13b5f16..9883f44 100644
--- a/common/resultset.cpp
+++ b/common/resultset.cpp
@@ -98,6 +98,22 @@ void ResultSet::skip(int number)
     }
 }
 
+qint64 ResultSet::replaySet(int offset, int batchSize, const Callback &callback)
+{
+    skip(offset);
+    int counter = 0;
+    while (!batchSize || (counter < batchSize)) {
+        const bool ret = next([this, &counter, callback](const ResultSet::Result &result) {
+                counter++;
+                callback(result);
+            });
+        if (!ret) {
+            break;
+        }
+    };
+    return counter;
+}
+
 QByteArray ResultSet::id()
 {
     if (mIt) {