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.



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