through - npm Package Compare versions

Comparing version 2.3.1 to 2.3.2

index.js

@@ -17,3 +17,3 @@ var Stream = require('stream')
 
-  var ended = false, destroyed = false, buffer = []
+  var ended = false, destroyed = false, buffer = [], _ended = false
   var stream = new Stream()
@@ -42,2 +42,5 @@ stream.readable = stream.writable = true
   stream.queue = stream.push = function (data) {
+//    console.error(ended)
+    if(_ended) return stream
+    if(data == null) _ended = true
     buffer.push(data)
@@ -44,0 +47,0 @@ drain()

package.json

 {
   "name": "through",
-  "version": "2.3.1",
+  "version": "2.3.2",
   "description": "simplified stream contruction",
@@ -5,0 +5,0 @@ "main": "index.js",

test/end.js

@@ -27,1 +27,20 @@ var test = require('tape')
 })
+
+test('end only once', function (t) {
+
+  var ts = through()
+  var ended = false, closed = false
+
+  ts.on('end', function () {
+    t.equal(ended, false)
+    ended = true
+  })
+
+  ts.queue(null)
+  ts.queue(null)
+  ts.queue(null)
+
+  ts.resume()
+
+  t.end()
+})

No alert changes

Improved metrics

Total package byte prevSize

11458

increased by3.26%

Lines of code

300

increased by5.63%

No dependency changes