Method: Async::IO::SharedEndpoint#connect

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

#connect ⇒ Object

[View source]

90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
 
# File 'lib/async/io/shared_endpoint.rb', line 90

def connect
	task = Async::Task.current
	
	@wrappers.each do |peer|
		peer = peer.dup
		
		task.async do |task|
			task.annotate "connected to #{peer.inspect} [#{peer.fileno}]"
			
			begin
				yield peer, task
			ensure
				peer.close
			end
		end
	end
end