scuttlebutt - npm Package Compare versions

Comparing version 3.3.0 to 3.3.1

index.js

@@ -226,3 +226,2 @@
     var data = out.shift()
-
     if(!data && !tail)
@@ -236,8 +235,19 @@ return this.emit('end'), null
 
+  function onUpdate (update) {
+    out.push(update)
+    rs.emit('readable')
+  }
+
   if(tail) {
-    this.on('_update', function (update) {
-      out.push(update)
-      rs.emit('readable')
-    })
+    this.on('_update', onUpdate)
   }
+  var self = this
+  rs.destroy = function () {
+    rs.removeListener('_update', onUpdate)
+    rs.emit('close')
+    //should this emit end?
+    //this is basically close,
+    //does readable-stream actually support this?
+    return this
+  }
 
@@ -244,0 +254,0 @@ this.once('dispose', function () {

package.json

@@ -5,3 +5,3 @@ {
   "description": "replicate data via scuttlebutt protocol",
-  "version": "3.3.0",
+  "version": "3.3.1",
   "homepage": "https://github.com/dominictarr/scuttlebutt",
@@ -15,3 +15,3 @@ "repository": {
     "duplex": "~0.1.3",
-    "stream-serializer": "0.0.0",
+    "stream-serializer": "0.0.1",
     "readable-stream": "~0.0.3",
@@ -18,0 +18,0 @@ "monotonic-timestamp": "0.0.2"

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

31012

increased by0.83%

Lines of code

661

increased by1.54%

Dependency changes

• + Addedstream-serializer@0.0.1(transitive)

• - Removedduplexer@0.1.2(transitive)

• - Removedevent-stream@3.0.20(transitive)

• - Removedfrom@0.1.7(transitive)

• - Removedmap-stream@0.0.7(transitive)

• - Removedpause-stream@0.0.11(transitive)

• - Removedsplit@0.2.10(transitive)

• - Removedstream-combiner@0.0.4(transitive)

• - Removedstream-serializer@0.0.0(transitive)

• - Removedthrough@2.3.8(transitive)

• Updatedstream-serializer@0.0.1