Connection: add missing message 'ended' assignment

11 years ago · 41cb2e2502
parent 9fd42bcbed
commit 41cb2e2502
1 changed files with 1 additions and 0 deletions
--- a/lib/Connection.js
+++ b/lib/Connection.js
@ -1120,6 +1120,7 @@ Connection.prototype._resUntagged = function(info) {

    if (toget.length === 0) {
      process.nextTick(function() {
+        msg.ended = true;
        msgEmitter.emit('attributes', attrs);
        msgEmitter.emit('end');
      });