lib/async/container/group.rb in async-container-0.16.8 vs lib/async/container/group.rb in async-container-0.16.9

- old
+ new

@@ -76,19 +76,19 @@ end # Interrupt all running processes. # This resumes the controlling fiber with an instance of {Interrupt}. def interrupt - Async.logger.debug(self, "Sending interrupt to #{@running.size} running processes...") + Console.logger.debug(self, "Sending interrupt to #{@running.size} running processes...") @running.each_value do |fiber| fiber.resume(Interrupt) end end # Terminate all running processes. # This resumes the controlling fiber with an instance of {Terminate}. def terminate - Async.logger.debug(self, "Sending terminate to #{@running.size} running processes...") + Console.logger.debug(self, "Sending terminate to #{@running.size} running processes...") @running.each_value do |fiber| fiber.resume(Terminate) end end