class ConnectedEndpoint

parameter　endpoint　Generic

The endpoint to connect.

option　close_on_exec　Boolean

Whether to close the socket on exec.

returns　ConnectedEndpoint

A new connected endpoint instance.

def self.connected(endpoint, close_on_exec: false)
	socket = endpoint.connect
	
	socket.close_on_exec = close_on_exec
	
	return self.new(endpoint, socket, **endpoint.options)
end

parameter　endpoint　Generic

The original endpoint that was connected.

parameter　socket　Socket

The socket that was connected.

parameter　options　Hash

Additional options to pass to the parent class.

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

attribute　Generic

The original endpoint that was connected.

attribute　Socket

The socket that was connected.

returns　AddressEndpoint

A endpoint for the local end of the connected socket.

def local_address_endpoint(**options)
	AddressEndpoint.new(socket.to_io.local_address, **options)
end

returns　AddressEndpoint

A endpoint for the remote end of the connected socket.

def remote_address_endpoint(**options)
	AddressEndpoint.new(socket.to_io.remote_address, **options)
end

parameter　wrapper　Wrapper

The wrapper to use (unused, socket is already connected).

yields　{|socket| ...}

If a block is given, yields the connected socket.

parameter　socket　Socket

The connected socket.

returns　Socket

The connected socket or a duplicate if no block is given.

def connect(wrapper = self.wrapper, &block)
	if block_given?
		yield @socket
	else
		return @socket.dup
	end
end

def close
	if @socket
		@socket.close
		@socket = nil
	end
end

returns　String

A string representation of the connected endpoint.

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

returns　String

A detailed string representation including the socket.

def inspect
	"\#<#{self.class} #{@socket} connected for #{@endpoint}>"
end