Sha256: 37f758d720356fe84f3d8bf0de258593a41646fa7412336726eae5d384d03c76

Contents?: true

Size: 1.13 KB

Versions: 27

Compression:

Stored size: 1.13 KB

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

  def receive_object obj # {:command => 'ping'}
    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', 33221, Echo
  EM.start_server '127.0.0.1', 33222, EchoObj
  EM.start_server "/tmp/em_test_sock", nil, Echo
  puts 'started'
end

Version data entries

27 entries across 27 versions & 3 rubygems

Version Path
eye-0.8.pre2 examples/processes/em.rb
eye-0.8.pre examples/processes/em.rb
eye-0.7 examples/processes/em.rb
eye-0.7.pre examples/processes/em.rb
eye-0.6.4 examples/processes/em.rb
eye-0.6.3 examples/processes/em.rb
eye-0.6.2 examples/processes/em.rb
eye-0.6.2.pre examples/processes/em.rb
ace-eye-0.6.5 examples/processes/em.rb
ace-eye-0.6.4 examples/processes/em.rb
eye-0.6.1 examples/processes/em.rb
ace-eye-0.6.3 examples/processes/em.rb
ace-eye-0.6.2 examples/processes/em.rb
ace-eye-0.6.1 examples/processes/em.rb
eye-0.6 examples/processes/em.rb
reel-eye-0.5.2.1 examples/processes/em.rb
reel-eye-0.5.2 examples/processes/em.rb
eye-0.5.2 examples/processes/em.rb
reel-eye-0.5.1 examples/processes/em.rb
eye-0.5.1 examples/processes/em.rb