Contents

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

    def post_init
      Log.info "Client Connected"
    end

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

    def unbind
      Log.info "Disconnected"
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
nfagent-0.9.17	lib/nfagent/event.rb
nfagent-0.9.15	lib/nfagent/event.rb
nfagent-0.9.13	lib/nfagent/event.rb
nfagent-0.9.11	lib/nfagent/event.rb
nfagent-0.9.10	lib/nfagent/event.rb