sample_comet_client.rb

# coding: utf-8

require "net/http"
require "uri"

def ping_pong(num)
  loop do
    puts "#{num.to_s}"
    uri = URI.parse 'http://localhost:8080/waiting'
    res = Net::HTTP.start(uri.host, uri.port).get(uri.path)
    EM::stop if res.code.to_i == 200
  end
end

threads = []
10.times do |i|
  threads << Thread.new(i) do |num|
    ping_pong(num)
  end
end

threads.each { |t| t.join }