Method: Async::IO::SharedEndpoint#bind

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

#bind ⇒ Object 



72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
 
# File 'lib/async/io/shared_endpoint.rb', line 72

def bind
  task = Async::Task.current
  
  @wrappers.each do |server|
    server = server.dup
    
    task.async do |task|
      task.annotate "binding to #{server.inspect}"
      
      begin
        yield server, task
      ensure
        server.close
      end
    end
  end
end