lib/connection/result/row_stream.js
function onResultStreamClose(err, continueCallback)
  {
    // if the error is retryable and
    // the result stream hasn't been closed too many times
    if (isResultStreamErrorRetryable(err) &&
        (numResultStreamInterrupts <
        context.connectionConfig.getResultStreamInterrupts()))
    {
      numResultStreamInterrupts++;

      // fetch the statement result again
      context.refresh(function()
      {
        if (context.resultError)
        {
          close(context.resultError);
        }
        else
        {
          continueCallback();
        }
      });
    }
    else
    {
      close(err);
    }
  }
function onResultStreamClose(err, continueCallback)
  {
    // if the error is retryable and
    // the result stream hasn't been closed too many times
    if (isResultStreamErrorRetryable(err) &&
        (numResultStreamInterrupts <
        context.connectionConfig.getResultStreamInterrupts()))
    {
      numResultStreamInterrupts++;

      // fetch the statement result again
      context.refresh(function()
      {
        if (context.resultError)
        {
          close(context.resultError);
        }
        else
        {
          continueCallback();
        }
      });
    }
    else
    {
      close(err);
    }
  }
function onResultStreamClose ( err , continueCallback ) { // if the error is retryable and // the result stream hasn't been closed too many times if ( isResultStreamErrorRetryable ( err ) && ( numResultStreamInterrupts < context . connectionConfig . getResultStreamInterrupts ( ) ) ) { numResultStreamInterrupts ++ ; // fetch the statement result again context . refresh ( function ( ) { if ( context . resultError ) { close ( context . resultError ) ; } else { continueCallback ( ) ; } } ) ; } else { close ( err ) ; } }
Called when there are no more chunks to read in the result stream or an
error is encountered while trying to read the next chunk.

@param err
@param continueCallback
Called when there are no more chunks to read in the result stream or an error is encountered while trying to read the next chunk .