class Async::Container::Group
def interrupt
Interrupt all running processes.
def interrupt Console.info(self, "Sending interrupt to #{@running.size} running processes...") @running.each_value do |fiber| fiber.resume(Interrupt) end end
def interrupt Console.info(self, "Sending interrupt to #{@running.size} running processes...") @running.each_value do |fiber| fiber.resume(Interrupt) end end