require_relative '../spec_helper'

module Kamerling describe NetDispatcher do
  describe '#dispatch' do
    it 'dispatches messages to TCP clients' do
      server = TCPServer.open 0
      thread = Thread.new { server.accept.read }
      addr   = Addr[server.addr[3], server.addr[1], :TCP]
      NetDispatcher.dispatch addr, 'foo'
      thread.value.must_equal 'foo'
    end

    it 'dispatches messages to UDP clients' do
      server = UDPSocket.new.tap { |s| s.bind '127.0.0.1', 0 }
      thread = Thread.new { server.recvfrom(2**16).first }
      addr   = Addr[server.addr[3], server.addr[1], :UDP]
      NetDispatcher.dispatch addr, 'foo'
      thread.value.must_equal 'foo'
    end
  end
end end