Connection: defer message 'attributes' and 'end' events until next tick

lib/Connection.js

@@ -1027,7 +1027,9 @@ Connection.prototype._resUntagged = function(info) {
     if (i === 0) {
       if (!msg.ended) {
         msg.ended = true;
-        msgEmitter.emit('end');
+        process.nextTick(function() {
+          msgEmitter.emit('end');
+        });
       }
       return;
     }
@@ -1047,8 +1049,10 @@ Connection.prototype._resUntagged = function(info) {
     }
 
     if (toget.length === 0) {
-      msgEmitter.emit('attributes', attrs);
+      process.nextTick(function() {
-      msgEmitter.emit('end');
+        msgEmitter.emit('attributes', attrs);
+        msgEmitter.emit('end');
+      });
     } else if (msg === undefined) {
       this._curReq.fetchCache[info.num] = {
         msgEmitter: msgEmitter,