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