diff --git a/package.json b/package.json
index ab8af05..c178dc7 100644
--- a/package.json
+++ b/package.json
@@ -197,14 +197,14 @@
     "@libp2p/logger": "^2.0.0",
     "err-code": "^3.0.1",
     "interface-datastore": "^7.0.0",
-    "it-all": "^1.0.4",
-    "it-drain": "^1.0.4",
-    "it-filter": "^1.0.2",
-    "it-map": "^1.0.5",
-    "it-merge": "^1.0.1",
+    "it-all": "^2.0.0",
+    "it-drain": "^2.0.0",
+    "it-filter": "^2.0.0",
+    "it-map": "^2.0.0",
+    "it-merge": "^2.0.0",
     "it-pipe": "^2.0.3",
     "it-pushable": "^3.0.0",
-    "it-take": "^1.0.1",
+    "it-take": "^2.0.0",
     "uint8arrays": "^4.0.2"
   },
   "devDependencies": {
diff --git a/src/mount.js b/src/mount.js
index 7a8de17..0260125 100644
--- a/src/mount.js
+++ b/src/mount.js
@@ -10,6 +10,7 @@ import {
 /**
  * @typedef {import('interface-datastore').Datastore} Datastore
  * @typedef {import('interface-datastore').Key} Key
+ * @typedef {import('interface-datastore').Pair} Pair
  * @typedef {import('interface-datastore').Options} Options
  * @typedef {import('interface-datastore').Batch} Batch
  * @typedef {import('interface-datastore').Query} Query
@@ -164,6 +165,7 @@ export class MountDatastore extends BaseDatastore {
       }, options)
     })
 
+    /** @type AsyncIterable<Pair> */
     let it = merge(...qs)
     if (q.filters) q.filters.forEach(f => { it = filter(it, f) })
     if (q.orders) q.orders.forEach(o => { it = sortAll(it, o) })
@@ -188,6 +190,7 @@ export class MountDatastore extends BaseDatastore {
       }, options)
     })
 
+    /** @type AsyncIterable<Key> */
     let it = merge(...qs)
     if (q.filters) q.filters.forEach(f => { it = filter(it, f) })
     if (q.orders) q.orders.forEach(o => { it = sortAll(it, o) })