Contents

module NFAgent
  class Event < EventMachine::Connection
    def initialize(chunk_handler)
      @handler = chunk_handler
    end

    def post_init
      Log.info "Client Connected"
    end

    def receive_data(data)
      if data && data.length > 2
        @handler.submit(data)
      end
      send_data('OK')
    end

    def unbind
      Log.info "Disconnected"
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
nfagent-0.9.0	lib/nfagent/event.rb
nfagent-0.0.99	lib/nfagent/event.rb
nfagent-0.0.1	lib/nfagent/event.rb