code: function Message(connection) {
    // Inherit from event emitter
    var that = this;
    EventEmitter.call(this);
  
    // Save the connection
    this.connection = connection;
  
    // If there is a body already, don't buffer
    if (connection.body) {
      that.body = connection.body;
      async.setImmediate(function () {
        that.emit('loaded');
      });
      return;
    }
  
    // Buffer the content of the connecftion
    connection.pipe(concat(function handleBuffer (buff) {
      // Save the body and emit a `loaded` event
      // DEV: The delay is so `async.waterfall` still operates when we enter it
      that.body = buff.length ? buff : '';
      async.setImmediate(function () {
        that.emit('loaded');
      });
    }));
  }
docs: Create connection