diff --git a/lib/server/rest.js b/lib/server/rest.js index df19b415..b316176f 100644 --- a/lib/server/rest.js +++ b/lib/server/rest.js @@ -147,9 +147,16 @@ else { lName = p.name; + lError = function(pError) { + main.sendError(pParams, pError); + }; + if (lQuery === 'zip') { lZlib = zlib.createGzip(); lReadStream = fs.createReadStream(lName); + + lReadStream.on('error', lError); + lReadStream = lReadStream.pipe(lZlib); lName += '.' + lQuery; lMsg = lQuery; @@ -160,10 +167,6 @@ lWriteStream = fs.createWriteStream(lName); - lError = function(pError) { - main.sendError(pParams, pError); - }; - lWriteStream.on('error', lError); lReadStream.on('error', lError);