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

    def associate_callback_target(sig)
      # Take no action
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
nfagent-0.9.31	lib/nfagent/event.rb
nfagent-0.9.27	lib/nfagent/event.rb
nfagent-0.9.26	lib/nfagent/event.rb
nfagent-0.9.20	lib/nfagent/event.rb
nfagent-0.9.19	lib/nfagent/event.rb