module Async::IO::Server
Public Instance Methods
accept_each(timeout: nil, task: Task.current) { |io, address, task: task| ... }
click to toggle source
# 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