hyperbee - npm Package Compare versions

Comparing version 2.12.0 to 2.12.1

index.js

@@ -366,3 +366,4 @@ const codecs = require('codecs')
   createReadStream (range, opts) {
-    return iteratorToStream(this.createRangeIterator(range, opts))
+    const signal = (opts && opts.signal) || null
+    return iteratorToStream(this.createRangeIterator(range, opts), signal)
   }
@@ -372,3 +373,4 @@
     const session = (opts && opts.live) ? this.core.session() : this._makeSnapshot()
-    return iteratorToStream(new HistoryIterator(new Batch(this, session, null, false, opts), opts))
+    const signal = (opts && opts.signal) || null
+    return iteratorToStream(new HistoryIterator(new Batch(this, session, null, false, opts), opts), signal)
   }
@@ -383,2 +385,3 @@
     const snapshot = right.version > this.version ? right._makeSnapshot() : this._makeSnapshot()
+    const signal = (opts && opts.signal) || null
 
@@ -388,3 +391,3 @@ const keyEncoding = opts && opts.keyEncoding ? codecs(opts.keyEncoding) : this.keyEncoding
 
-    return iteratorToStream(new DiffIterator(new Batch(this, snapshot, null, false, opts), new Batch(right, snapshot, null, false, opts), opts))
+    return iteratorToStream(new DiffIterator(new Batch(this, snapshot, null, false, opts), new Batch(right, snapshot, null, false, opts), opts), signal)
   }
@@ -640,3 +643,4 @@
   createReadStream (range, opts) {
-    return iteratorToStream(this.createRangeIterator(range, opts))
+    const signal = (opts && opts.signal) || null
+    return iteratorToStream(this.createRangeIterator(range, opts), signal)
   }
@@ -1252,3 +1256,3 @@
 
-function iteratorToStream (ite) {
+function iteratorToStream (ite, signal) {
   let done
@@ -1258,2 +1262,3 @@ let closing
   const rs = new Readable({
+    signal,
     open (cb) {
@@ -1260,0 +1265,0 @@ done = cb

package.json

 {
   "name": "hyperbee",
-  "version": "2.12.0",
+  "version": "2.12.1",
   "description": "An append-only B-tree running on a Hypercore.",
@@ -5,0 +5,0 @@ "main": "index.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

89852

increased by0.28%

Lines of code

2486

increased by0.2%

No dependency changes