fix: resolve sync promise if there are more entries locally than on p…

…inning node
3box · Jan 25, 2019 · 826dd67 · 826dd67
1 parent 3e6eec5
commit 826dd67
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/keyValueStore.js b/src/keyValueStore.js
@@ -51,7 +51,7 @@ class KeyValueStore {
   async _sync (numRemoteEntries) {
     this._requireLoad()
     // let toid = null
-    if (numRemoteEntries === this._db._oplog.values.length) return Promise.resolve()
+    if (numRemoteEntries <= this._db._oplog.values.length) return Promise.resolve()
     await new Promise((resolve, reject) => {
       if (!numRemoteEntries) {
         setTimeout(() => {
@@ -61,7 +61,7 @@ class KeyValueStore {
         }, 3000)
       }
       this._db.events.on('replicated', () => {
-        if (numRemoteEntries === this._db._oplog.values.length) resolve()
+        if (numRemoteEntries <= this._db._oplog.values.length) resolve()
       })
       /*
       this._db.events.on('replicate.progress', (_x, _y, _z, num, max) => {