EM Echo server using watch.rb

require 'rubygems'
require 'preforker'
require 'eventmachine'

class EchoServer < EM::Connection
  def notify_readable
    while socket = @io.accept_nonblock
      message = socket.gets
      socket.write message
      socket.close
    end
  rescue Errno::EAGAIN, Errno::ECONNABORTED
  end

  def close
    puts "closing"
    detach
    @io.close
  end
end

socket = TCPServer.new("0.0.0.0", 8081)
socket.listen(10)

EventMachine.epoll
EventMachine::run do
  EM.watch(socket, EchoServer, self){ |c| c.notify_readable = true}
  puts "Listening..."
end

require 'rubygems'
require 'preforker'
require 'eventmachine'

class EchoServer < EM::Connection
def notify_readable
while socket = @io.accept_nonblock
message = socket.gets
socket.write message
socket.close
end
rescue Errno::EAGAIN, Errno::ECONNABORTED
end

def close
puts "closing"
detach
@io.close
end
end

socket = TCPServer.new("0.0.0.0", 8081)
socket.listen(10)

EventMachine.epoll
EventMachine::run do
EM.watch(socket, EchoServer, self){ |c| c.notify_readable = true}
puts "Listening..."
end