feat: add streaming/cancellable API

package.json

@@ -37,12 +37,12 @@
   },
   "homepage": "https://github.com/ipfs/js-datastore-level#readme",
   "dependencies": {
-    "datastore-core": "^1.0.0",
-    "interface-datastore": "^0.8.0",
+    "datastore-core": "^1.1.0",
+    "interface-datastore": "^1.0.2",
     "level": "^5.0.1"
   },
   "devDependencies": {
-    "aegir": "^21.9.0",
+    "aegir": "^22.0.0",
     "chai": "^4.2.0",
     "cids": "^0.8.0",
     "dirty-chai": "^2.0.1",

src/index.js

@@ -1,13 +1,19 @@
 'use strict'
 
-const { Key, Errors, utils } = require('interface-datastore')
-const { filter, map, take, sortAll } = utils
+const {
+  Key, Errors, Adapter,
+  utils: {
+    filter, map, take, sortAll
+  }
+} = require('interface-datastore')
 
 /**
  * A datastore backed by leveldb.
  */
-class LevelDatastore {
+class LevelDatastore extends Adapter {
   constructor (path, opts) {
+    super()
+
     let database
 
     if (opts && opts.db) {
@@ -93,8 +99,8 @@ class LevelDatastore {
           key: key.toString()
         })
       },
-      commit: () => {
-        return this.db.batch(ops)
+      commit: (options) => {
+        return this.db.batch(ops, options)
       }
     }
   }