pull-stream - npm Package Compare versions

Comparing version 2.9.1 to 2.9.2

package.json

 {
   "name": "pull-stream",
   "description": "minimal pull stream",
-  "version": "2.9.1",
+  "version": "2.9.2",
   "homepage": "https://github.com/dominictarr/pull-stream",
@@ -6,0 +6,0 @@ "repository": {

sources.js

@@ -27,3 +27,3 @@
     if(end) return cb && cb(end)
-    if(max <= i)
+    if(i > max)
       return cb(true)
@@ -30,0 +30,0 @@ cb(null, i++)

test/through.js

@@ -10,3 +10,5 @@
     t.ok(true)
-    t.end()
+    process.nextTick(function () {
+      t.end()
+    })
   }))
@@ -13,0 +15,0 @@ .pipe(pull.take(10))

throughs.js

@@ -77,22 +77,18 @@ function prop (map) {
     var n = test; test = function () {
-      return n-- > 0
+      return n --> 0
     }
   }
   return function (end, cb) {
-    if(end) {
-      if(!ended) return ended = end, read(end, cb)
-      cb(ended)
-    }
-    return read(null, function (end, data) {
-      if(ended) return
-      if(end) return cb(ended = end)
+    if(ended = ended || end)
+      return read(ended, cb)
+
+    read(null, function (end, data) {
+      if(ended = ended || end) return cb(ended)
       //TODO, CHECK THAT END LOGIC IS CORRECT WITH TAKE!!!
       if(!test(data)) {
         ended = true
-        nextTick(function () {
-          read(true, function (){})
-        })
-        return cb(true)
+        read(true, cb)
       }
-      return cb(null, data)
+      else 
+        cb(null, data)
     })
@@ -99,0 +95,0 @@ }

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

Worsened metrics

Total package byte prevSize

29804

decreased by-0.25%

Lines of code

736

decreased by-0.41%

No dependency changes