       @request.rowCount = 0
       @request.rows = []
 
+      @createRequestTimer()
+
       @messageIo.sendMessage(packetType, payload.data, @resetConnectionOnNextRequest)
       @resetConnectionOnNextRequest = false
       @debug.payload(->

    )
    @tokenStreamParser.on('done', (token) =>
      if @request
        @request.emit('done', token.rowCount, token.more, @request.rows)
        
        if token.rowCount != undefined
          @request.rowCount += token.rowCount

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

        data: (data) ->
          @sendDataToTokenStreamParser(data)
        message: ->
          @clearRequestTimer()
          @transitionTo(@STATE.LOGGED_IN)

          sqlRequest = @request
