Method: Async::IO::SharedEndpoint.connected

Defined in:
lib/async/io/shared_endpoint.rb

.connected(endpoint, close_on_exec: false) ⇒ Object

Create a new ‘SharedEndpoint` by connecting to the given endpoint.

[View source]

47
48
49
50
51
52
53
54
 
# File 'lib/async/io/shared_endpoint.rb', line 47

def self.connected(endpoint, close_on_exec: false)
	wrapper = endpoint.connect
	
	wrapper.close_on_exec = close_on_exec
	wrapper.reactor = nil
	
	return self.new(endpoint, [wrapper])
end