diff --git a/packages/local-sync/src/shared/database-extensions.js b/packages/local-sync/src/shared/database-extensions.js
index 4c64073fb..5863a8b77 100644
--- a/packages/local-sync/src/shared/database-extensions.js
+++ b/packages/local-sync/src/shared/database-extensions.js
@@ -11,7 +11,7 @@ Sequelize.Model.prototype.streamAll = function streamAll(options = {}) {
       this.findAll(opts).then((models = []) => {
         observer.onNext(models)
         if (models.length === chunkSize) {
-          opts.offset = chunkSize;
+          opts.offset += chunkSize;
           findFn(opts)
         } else {
           observer.onCompleted()