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

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

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

        if token.sqlError && !@request.error
          @request.error = RequestError('An unknown error has occurred.', 'UNKNOWN')

        @request.emit('done', token.rowCount, token.more, @request.rst)

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

        if @config.options.rowCollectionOnDone
          @request.rst = []
    )
    @tokenStreamParser.on('resetConnection', (token) =>
      @emit('resetConnection')
