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