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