diff --git a/lib/Connection.js b/lib/Connection.js
index 1cc5e38..a064347 100644
--- a/lib/Connection.js
+++ b/lib/Connection.js
@@ -1088,9 +1088,12 @@ Connection.prototype._resTagged = function(info) {
   }
 
   if (req.bodyEmitter) {
+    var bodyEmitter = req.bodyEmitter;
     if (err)
-      req.bodyEmitter.emit('error', err);
-    req.bodyEmitter.emit('end');
+      bodyEmitter.emit('error', err);
+    process.nextTick(function() {
+      bodyEmitter.emit('end');
+    });
   } else {
     req.cbargs.unshift(err);
     req.cb && req.cb.apply(this, req.cbargs);