Sha256: a590ba19ee56bb9121edfb12545442f6ebe830647a9f0c78fa930c89b0dbd518
Contents?: true
Size: 1.57 KB
Versions: 22
Compression:
Stored size: 1.57 KB
Contents
require 'libuv'
require 'thread'
describe Libuv::UDP do
before :each do
@log = []
@general_failure = []
@reactor = Libuv::Reactor.new
@server = @reactor.udp
@client = @reactor.udp
@timeout = @reactor.timer do
@reactor.stop
@general_failure << "test timed out"
end
@timeout.start(5000)
@reactor.notifier do |error, context|
begin
@general_failure << "Log called: #{context}\n#{error.message}\n#{error.backtrace.join("\n") if error.backtrace}\n"
rescue Exception => e
@general_failure << "error in logger #{e.inspect}"
end
end
@reactor.all(@server, @client, @timeout).catch do |reason|
@general_failure << reason.inspect
end
end
describe 'basic client server' do
it "should send a ping and return a pong", :network => true do
@reactor.run { |reactor|
@server.bind('127.0.0.1', 34567)
@server.progress do |data, ip, port, server|
@log << data
server.send(ip, port, 'pong')
end
@server.start_read
# catch errors
@server.catch do |reason|
@general_failure << reason.inspect
end
# connect client to server
@client.bind('127.0.0.1', 34568)
@client.progress do |data, ip, port, client|
@log << data
client.close
end
@client.start_read
@client.send('127.0.0.1', 34567, 'ping')
# catch errors
@client.catch do |reason|
@general_failure << reason.inspect
end
# close the handle
@client.finally do
@server.close
@reactor.stop
end
}
expect(@log).to eq(['ping', 'pong'])
expect(@general_failure).to eq([])
end
end
end
Version data entries
22 entries across 22 versions & 1 rubygems