Contents

require 'bundler/setup'
require 'eventmachine'

def answer(data)
  case data
    when 'ping' then "pong\n"
    when 'bad' then "what\n"
    when 'timeout' then
      sleep 5
      "ok\n"
    when 'exception' then raise 'haha'
    when 'quit' then EM.stop
    when 'big' then 'a' * 10_000_000
  end
end

class Echo < EM::Connection

  def post_init
    puts '-- someone connected to the echo server!'
  end

  def receive_data(data)
    puts "receive #{data.inspect} "
    send_data(answer(data))
  end

  def unbind
    puts '-- someone disconnected from the echo server!'
  end

end

class EchoObj < EM::Connection

  include EM::P::ObjectProtocol

  def post_init
    puts '-- someone connected to the echo server!'
  end

  # {:command => 'ping'}
  def receive_object(obj)
    puts "receive #{obj.inspect}"
    send_object(answer(obj[:command]).chop)
  end

  def unbind
    puts '-- someone disconnected from the echo server!'
  end

end

trap 'QUIT' do
  puts 'quit signal, stopping'
  EM.stop
end

EM.run do
  EM.start_server '127.0.0.1', 33_221, Echo
  EM.start_server '127.0.0.1', 33_222, EchoObj
  EM.start_server '/tmp/em_test_sock', nil, Echo
  puts 'started'
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
eye-0.10.1.pre	examples/processes/em.rb
eye-0.10.0	examples/processes/em.rb
eye-0.10.0.alpha2	examples/processes/em.rb
eye-0.10.0.alpha	examples/processes/em.rb
eye-0.9.4.nosigar	examples/processes/em.rb
eye-0.9.4	examples/processes/em.rb
eye-0.9.3	examples/processes/em.rb