lib/connection/result/row_stream.js
function readNextRow()
  {
    // if we have a row buffer, process it
    if (rowBuffer)
    {
      processRowBuffer();
    }
    else
    {
      // subscribe to the result stream's 'data' and 'close' events
      resultStream.on('data', onResultStreamData);
      resultStream.on('close', onResultStreamClose);

      // issue a request to fetch the next chunk in the result stream
      resultStream.read();
    }
  }
function readNextRow()
  {
    // if we have a row buffer, process it
    if (rowBuffer)
    {
      processRowBuffer();
    }
    else
    {
      // subscribe to the result stream's 'data' and 'close' events
      resultStream.on('data', onResultStreamData);
      resultStream.on('close', onResultStreamClose);

      // issue a request to fetch the next chunk in the result stream
      resultStream.read();
    }
  }
function readNextRow ( ) { // if we have a row buffer, process it if ( rowBuffer ) { processRowBuffer ( ) ; } else { // subscribe to the result stream's 'data' and 'close' events resultStream . on ( 'data' , onResultStreamData ) ; resultStream . on ( 'close' , onResultStreamClose ) ; // issue a request to fetch the next chunk in the result stream resultStream . read ( ) ; } }
Called when we're ready to read the next row in the result.
Called when we re ready to read the next row in the result .