class EventMachine::Reactor

def open_loopbreaker
  # Can't use an IO.pipe because they can't be set nonselectable in Windows.
  # Pick a random localhost UDP port.
  #@loopbreak_writer.close if @loopbreak_writer
  #rd,@loopbreak_writer = IO.pipe
  @loopbreak_reader = UDPSocket.new
  @loopbreak_writer = UDPSocket.new
  bound = false
  100.times {
    @loopbreak_port = rand(10000) + 40000
    begin
      @loopbreak_reader.bind "127.0.0.1", @loopbreak_port
      bound = true
      break
    rescue
    end
  }
  raise "Unable to bind Loopbreaker" unless bound
  LoopbreakReader.new(@loopbreak_reader)
end