lib/connection.js
function data(buf) {
  if(this._tcp) {
    if(this._paused) {
      this.client._qbuf = Buffer.concat(
        [this.client._qbuf, buf], this.client._qbuf.length + buf.length);
      return false;
    }
    this.emit('input', buf.length);
    this._process(buf);
  }else{
    // TODO: handle pausing internal connections!

    // not actually a buffer for internal sockets
    // rather the raw request itself, ie: array with command
    // and arguments
    this.decoded(null, buf);
  }
}
function data(buf) {
  if(this._tcp) {
    if(this._paused) {
      this.client._qbuf = Buffer.concat(
        [this.client._qbuf, buf], this.client._qbuf.length + buf.length);
      return false;
    }
    this.emit('input', buf.length);
    this._process(buf);
  }else{
    // TODO: handle pausing internal connections!

    // not actually a buffer for internal sockets
    // rather the raw request itself, ie: array with command
    // and arguments
    this.decoded(null, buf);
  }
}
function data ( buf ) { if ( this . _tcp ) { if ( this . _paused ) { this . client . _qbuf = Buffer . concat ( [ this . client . _qbuf , buf ] , this . client . _qbuf . length + buf . length ) ; return false ; } this . emit ( 'input' , buf . length ) ; this . _process ( buf ) ; } else { // TODO: handle pausing internal connections! // not actually a buffer for internal sockets // rather the raw request itself, ie: array with command // and arguments this . decoded ( null , buf ) ; } }
Read incoming data on the socket connection.

@param buf The incoming buffer or internal request
array.
Read incoming data on the socket connection .