module Async::IO::Server

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
		end
	end
end