Sha256: bd3141f9822d7cf644872cf5c7fe180f437c2f0b7cfe4d3e3af18e30faa0043c
Contents?: true
Size: 1.02 KB
Versions: 16
Compression:
Stored size: 1.02 KB
Contents
# frozen_string_literal: true
require "spec_helper"
RSpec.describe UDPSocket, if: !defined?(JRUBY_VERSION) do
let(:udp_port) { 23_456 }
let :readable_subject do
server = UDPSocket.new
server.bind("127.0.0.1", 0)
peer = UDPSocket.new
peer.send("hi there", 0, "127.0.0.1", server.local_address.ip_port)
server
end
let :unreadable_subject do
sock = UDPSocket.new
sock.bind("127.0.0.1", 0)
sock
end
let :writable_subject do
server = UDPSocket.new
server.bind("127.0.0.1", 0)
peer = UDPSocket.new
peer.connect("127.0.0.1", server.local_address.ip_port)
cntr = 0
begin
peer.send("X" * 1024, 0)
cntr += 1
t = select [], [peer], [], 0
rescue Errno::ECONNREFUSED => ex
skip "Couldn't make writable UDPSocket subject: #{ex.class}: #{ex}"
end while t && t[1].include?(peer) && cntr < 5
peer
end
let :unwritable_subject do
pending "come up with a UDPSocket that's blocked on writing"
end
it_behaves_like "an NIO selectable"
end
Version data entries
16 entries across 16 versions & 6 rubygems