chore: process queries in own tx

ipfs · Jun 10, 2020 · 16c2301 · 16c2301
1 parent e43eda4
commit 16c2301
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/index.js b/src/index.js
@@ -106,6 +106,10 @@ class IdbDatastore extends Adapter {
   }
 
   async * _queryIt (q) {
+    if (this._tx) {
+      await this._tx.done
+    }
+
     const range = q.prefix ? self.IDBKeyRange.bound(str2ab(q.prefix), str2ab(q.prefix + '\xFF'), false, true) : undefined
     const store = this._getStore()
     let cursor = await store.openCursor(range)
@@ -131,6 +135,8 @@ class IdbDatastore extends Adapter {
       }
       cursor = await cursor.continue()
     }
+
+    await this._tx.done
   }
 
   async open () {