module Kamerling module Server class TCP < Sock
  private

  def handle_connection socket
    client_addr = Addr[*socket.remote_address.ip_unpack, :TCP]
    input       = socket.read
    handle input, client_addr
  ensure
    socket.close
  end

  def run_loop
    Socket.tcp_server_loop(*addr) { |socket| handle_connection socket }
  end

  def wait_till_started
    loop { break if addr.connectable? }
  end
end end end