Module: Async::IO::Server
Instance Method Summary collapse
Instance Method Details
#accept_each(timeout: nil, task: Task.current) ⇒ Object
28 29 30 31 32 33 34 35 36 37 38 |
# File 'lib/async/io/server.rb', line 28 def accept_each(timeout: nil, task: Task.current) task.annotate "accepting connections #{self.local_address.inspect} [fd=#{self.fileno}]" callback = lambda do |io, address| yield io, address, task: task end while true self.accept(timeout: timeout, task: task, &callback) end end |