Module: Async::IO::Server
Instance Method Summary collapse
Instance Method Details
#accept_each(task: Task.current) ⇒ Object
41 42 43 44 45 46 47 48 49 |
# File 'lib/async/io/socket.rb', line 41 def accept_each(task: Task.current) task.annotate "accepting connections #{self.local_address.inspect}" while true self.accept(task: task) do |io, address| yield io, address, task: task end end end |