lib/connection/result/row_stream.js
function(err)
  {
    // if we have a result stream, stop listening to events on it
    if (resultStream)
    {
      resultStream.removeListener('data', onResultStreamData);
      resultStream.removeListener('close', onResultStreamClose);
    }

    // we're done, so time to clean up
    rowBuffer = null;
    rowIndex = 0;
    resultStream = null;
    numResultStreamInterrupts = 0;

    if (err)
    {
      emitError(err);
    }
    else
    {
      self.push(null);
    }
  }
function(err)
  {
    // if we have a result stream, stop listening to events on it
    if (resultStream)
    {
      resultStream.removeListener('data', onResultStreamData);
      resultStream.removeListener('close', onResultStreamClose);
    }

    // we're done, so time to clean up
    rowBuffer = null;
    rowIndex = 0;
    resultStream = null;
    numResultStreamInterrupts = 0;

    if (err)
    {
      emitError(err);
    }
    else
    {
      self.push(null);
    }
  }
function ( err ) { // if we have a result stream, stop listening to events on it if ( resultStream ) { resultStream . removeListener ( 'data' , onResultStreamData ) ; resultStream . removeListener ( 'close' , onResultStreamClose ) ; } // we're done, so time to clean up rowBuffer = null ; rowIndex = 0 ; resultStream = null ; numResultStreamInterrupts = 0 ; if ( err ) { emitError ( err ) ; } else { self . push ( null ) ; } }
Closes the row stream.

@param {Error} [err]
Closes the row stream .