pipe-io - npm Package Compare versions

Comparing version 1.1.22 to 1.1.23

lib/pipe.js

@@ -33,2 +33,6 @@ (function () {
             
+            rm              = function(event, stream, fn) {
+                stream.removeListener(event, fn);
+            },
+            
             onWriteError    =  function(error) {
@@ -73,24 +77,23 @@ writeError = true;
         function onResult() {
-            var is;
-            
             if (readError && finish) {
-                is = true;
-                write.removeListener('error', onWriteError);
-                read.removeListener('end', onReadEnd);
+                rm('error', write, onWriteError);
+                rm('end', read, onReadEnd);
+                
+                onEnd();
             } else if (writeError && readError) {
-                is = true;
-                read.removeListener('end', onReadEnd);
-                write.removeListener('finish', onWriteFinish);
+                rm('end', read, onReadEnd);
+                rm('finish', write, onWriteFinish);
+                
+                onEnd();
             } else if (writeError && end) {
-                is = true;
-                write.removeListener('finish', onWriteFinish);
-                read.removeListener('error', onReadError);
+                rm('finish', write, onWriteFinish);
+                rm('error', read, onReadError);
+                
+                onEnd();
             } else if (end || finish) {
-                is = true;
-                read.removeListener('error', onReadError);
-                write.removeListener('error', onWriteError);
-            
+                rm('error', read, onReadError);
+                rm('error', write, onWriteError);
+                
+                onEnd();
             }
-            if (is)
-                onEnd();
         }
@@ -97,0 +100,0 @@

package.json

 {
   "name": "pipe-io",
-  "version": "1.1.22",
+  "version": "1.1.23",
   "author": "coderaiser <[e-mail]> (https://github.com/coderaiser)",
@@ -5,0 +5,0 @@ "description": "Pipe streams and handle events",

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

9283

increased by0.79%

No dependency changes