From f32d0df7e03cf451417f37037fcf001da942e8ca Mon Sep 17 00:00:00 2001
From: Mark Hahnenberg <mhahnenb@gmail.com>
Date: Fri, 9 Dec 2016 11:15:04 -0800
Subject: [PATCH] [local-sync] Increment streamAll offset by chunkSize (#5)

Otherwise we'll infinite loop if there are more than 2000 results.
---
 packages/local-sync/src/shared/database-extensions.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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()