@@ -392,13 +392,26 @@ internals.payload = function (request, next) {
 
         // Flush out any pending request payload not consumed due to errors or other restrictions
 
-        request.raw.req.once('end', function () {
+        var stream = request.raw.req;
+
+        var read = function () {
+
+            stream.read();
+        };
+
+        var end = function () {
+
+            stream.removeListener('readable', read);
+            stream.removeListener('error', end);
+            stream.removeListener('end', end);
 
             request._isPayloadPending = false;
             return onParsed(err, parsed);
-        });
+        };
 
-        request.raw.req.resume();
+        stream.on('readable', read);
+        stream.once('error', end);
+        stream.once('end', end);
     });
 };