diff --git a/lib/server/pipe.js b/lib/server/pipe.js index a5770b36..5e9a3580 100644 --- a/lib/server/pipe.js +++ b/lib/server/pipe.js @@ -46,8 +46,14 @@ lRead.on('error', lError); Util.ifExec(!lIsFsWrite, function() { - lRead.pipe(lWrite); - lRead.on('end', Util.retExec(p.callback)); + lRead.on('data', function(data) { + lWrite.write(data); + }); + + lRead.on('end', function() { + lWrite.end(); + Util.exec(p.callback); + }); }, function(pCallBack) { lWrite.on('open', pCallBack); });