Contents

require 'socket'
require_relative '../addr'
require_relative 'sock'

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

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
kamerling-0.0.3	lib/kamerling/server/tcp.rb