Module: Async::IO::Server
Instance Method Summary collapse
Instance Method Details
#accept_each(timeout: nil, task: Task.current) ⇒ Object
90 91 92 93 94 95 96 97 98 |
# File 'lib/async/io/socket.rb', line 90 def accept_each(timeout: nil, task: Task.current) task.annotate "accepting connections #{self.local_address.inspect}" while true self.accept(timeout: timeout, task: task) do |io, address| yield io, address, task: task end end end |