class BoundEndpoint

parameter　endpoint　Generic

The endpoint to bind.

option　backlog　Integer

The maximum length of the queue of pending connections.

option　close_on_exec　Boolean

Whether to close sockets on exec.

returns　BoundEndpoint

A new bound endpoint instance.

def self.bound(endpoint, backlog: Socket::SOMAXCONN, close_on_exec: false)
	sockets = endpoint.bind
	
	sockets.each do |socket|
		socket.close_on_exec = close_on_exec
	end
	
	return self.new(endpoint, sockets, **endpoint.options)
end

parameter　endpoint　Generic

The original endpoint that was bound.

parameter　sockets　Array(Socket)

The sockets that were bound.

parameter　options　Hash

Additional options to pass to the parent class.

def initialize(endpoint, sockets, **options)
	super(**options)
	
	@endpoint = endpoint
	@sockets = sockets
end

attribute　Generic

The original endpoint that was bound.

attribute　Array(Socket)

The sockets that were bound.

returns　CompositeEndpoint

A composite endpoint for the local end of the bound socket.

def local_address_endpoint(**options)
	endpoints = @sockets.map do |socket|
		AddressEndpoint.new(socket.to_io.local_address, **options)
	end
	
	return CompositeEndpoint.new(endpoints)
end

returns　CompositeEndpoint

A composite endpoint for the remote end of the bound socket.

def remote_address_endpoint(**options)
	endpoints = @sockets.map do |wrapper|
		AddressEndpoint.new(socket.to_io.remote_address, **options)
	end
	
	return CompositeEndpoint.new(endpoints)
end

def close
	@sockets.each(&:close)
	@sockets.clear
end

returns　String

A string representation of the bound endpoint.

def to_s
	"bound:#{@endpoint}"
end

returns　String

A detailed string representation including socket count.

def inspect
	"\#<#{self.class} #{@sockets.size} bound sockets for #{@endpoint}>"
end

parameter　wrapper　Wrapper

The wrapper to use for binding.

yields　{|socket| ...}

If a block is given, yields each bound socket.

parameter　socket　Socket

A bound socket.

returns　Array(Socket)

An array of bound sockets.

def bind(wrapper = self.wrapper, &block)
	@sockets.map do |server|
		if block_given?
			wrapper.schedule do
				yield server
			end
		else
			server.dup
		end
	end
end