From b02e35ed977913144987200ae3d71ed229c5e6aa Mon Sep 17 00:00:00 2001 From: coderaiser Date: Fri, 9 Aug 2013 12:19:12 +0000 Subject: [PATCH] fix(rest) add lReadStream.on(error, lError) --- lib/server/rest.js | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) 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);