Comparing version 1.2.5 to 1.2.6
@@ -44,2 +44,6 @@ 'use strict'; | ||
isGzip = allStreams.some(function(write) { | ||
return write instanceof zlib.Gzip | ||
}), | ||
rm = function(event, stream, fn) { | ||
@@ -117,4 +121,2 @@ stream.removeListener(event, fn); | ||
onEnd(); | ||
} else if (writeError && isGunzip) { | ||
onEnd(); | ||
} else if (open && readError) { | ||
@@ -124,3 +126,3 @@ onEnd(); | ||
onEnd(); | ||
} else if (error && isGunzip) { | ||
} else if (error && (isGzip || isGunzip)) { | ||
onEnd(); | ||
@@ -127,0 +129,0 @@ } |
{ | ||
"name": "pipe-io", | ||
"version": "1.2.5", | ||
"version": "1.2.6", | ||
"author": "coderaiser <mnemonic.enemy@gmail.com> (https://github.com/coderaiser)", | ||
@@ -5,0 +5,0 @@ "description": "Pipe streams and handle events", |
@@ -18,10 +18,10 @@ Pipe-io [![License][LicenseIMGURL]][LicenseURL] [![NPM version][NPMIMGURL]][NPMURL] [![Dependency Status][DependencyStatusIMGURL]][DependencyStatusURL] [![Build Status][BuildStatusIMGURL]][BuildStatusURL] [![Coverage Status][CoverageIMGURL]][CoverageURL] | ||
```js | ||
var pipe = require('pipe-io'), | ||
fs = require('fs'), | ||
NAME = 'README.md', | ||
NAME2 = 'README2.md', | ||
readStream = fs.createReadStream(NAME), | ||
writeStream = fs.createWriteStream(NAME2); | ||
const pipe = require('pipe-io'); | ||
const fs = require('fs'); | ||
const NAME = 'README.md'; | ||
const NAME2 = 'README2.md'; | ||
const readStream = fs.createReadStream(NAME); | ||
const writeStream = fs.createWriteStream(NAME2); | ||
pipe([readStream, writeStream], function(error) { | ||
pipe([readStream, writeStream], (error) => { | ||
console.log(error || 'done'); | ||
@@ -35,8 +35,8 @@ }); | ||
```js | ||
var pipe = require('pipe-io'), | ||
fs = require('fs'), | ||
NAME = 'README.md', | ||
readStream = fs.createReadStream(NAME); | ||
const pipe = require('pipe-io'); | ||
const fs = require('fs'); | ||
const NAME = 'README.md'; | ||
const readStream = fs.createReadStream(NAME); | ||
pipe.getBody(readStream, function(error, data) { | ||
pipe.getBody(readStream, (error, data) => { | ||
console.log(error || data); | ||
@@ -62,1 +62,2 @@ }); | ||
[CoverageURL]: https://coveralls.io/github/coderaiser/pipe-io?branch=master | ||
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
12214
151
61