class Async::Container::Group
def wait_for_children(duration = nil)
def wait_for_children(duration = nil) # This log is a big noisy and doesn't really provide a lot of useful information. # Console.debug(self, "Waiting for children...", duration: duration, running: @running) if !@running.empty? # Maybe consider using a proper event loop here: if ready = self.select(duration) ready.each do |io| @running[io].resume end end end end