diff --git a/lib/server/pipe.js b/lib/server/pipe.js index 7e4b3bdb..9add05c2 100644 --- a/lib/server/pipe.js +++ b/lib/server/pipe.js @@ -102,16 +102,18 @@ function getBody(readStream, callback) { var body = ''; + Util.checkArgs(arguments, ['readStream', 'callback']); + readStream.on('data', function(chunk) { body += chunk; }); readStream.once('error', function(error) { - Util.exec.ret(callback, error); + callback(error); }); readStream.once('end', function() { - Util.exec(callback, null, body); + callback(null, body); }); } })();