       @request = request
       @request.rowCount = 0
       @request.rows = []
+      @request.rst = []
 
       @createRequestTimer()
 

    )
    @tokenStreamParser.on('doneProc', (token) =>
      if @request
        @request.emit('doneProc', token.rowCount, token.more, @procReturnStatusValue, @request.rows)
        @procReturnStatusValue = undefined

        if token.rowCount != undefined
          @request.rowCount += token.rowCount

        if @config.options.rowCollectionOnDone
          @request.rows = []
    )
    @tokenStreamParser.on('doneInProc', (token) =>
      if @request
        @request.emit('doneInProc', token.rowCount, token.more, @request.rows)

        if token.rowCount != undefined
          @request.rowCount += token.rowCount

        if @config.options.rowCollectionOnDone
          @request.rows = []
    )
    @tokenStreamParser.on('done', (token) =>
      if @request

    )
    @tokenStreamParser.on('row', (token) =>
      if @request
        if @config.options.rowCollectionOnRequestCompletion
          @request.rows.push token.columns
        
        if @config.options.rowCollectionOnDone
          @request.rst.push token.columns

        @request.emit('row', token.columns)
      else
