pull-stream-to-stream - npm Package Compare versions

Comparing version 1.2.3 to 1.2.4

index.js

@@ -20,4 +20,5 @@
   s.end = function () {
-    ended = true
-    if(cbs.length)
+    if(read)
+      read(ended = true, cbs.length ? cbs.shift() : function () {})
+    else if(cbs.length)
       cbs.shift()(true)      
@@ -24,0 +25,0 @@ }

package.json

 {
   "name": "pull-stream-to-stream",
   "description": "",
-  "version": "1.2.3",
+  "version": "1.2.4",
   "homepage": "https://github.com/dominictarr/pull-stream-to-stream",
@@ -6,0 +6,0 @@ "repository": {

test/close.js

@@ -22,1 +22,17 @@
 })
+
+require('tape')('test end', function (t) {
+
+  t.plan(10)
+
+  var i = 10
+  var cs = CS(null, pull.infinite().pipe(pull.through(null, function () {
+    console.log('ENDED')
+    t.end()
+  })))
+  .on('data', function (data) {
+    t.ok(data)
+    if(!--i) cs.end()
+  })
+
+})

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

7269

increased by4.86%

Lines of code

229

increased by6.02%

No dependency changes