code: 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);
      }
    }
docs: Closes the row stream.
  
  @param {Error} [err]