lib/async/container/group.rb in async-container-0.16.4 vs lib/async/container/group.rb in async-container-0.16.5
- old
+ new
@@ -67,15 +67,17 @@
self.wait_for_children
end
end
def interrupt
+ Async.logger.debug(self, "Sending interrupt to #{@running.size} running processes...")
@running.each_value do |fiber|
fiber.resume(Interrupt)
end
end
def terminate
+ Async.logger.debug(self, "Sending terminate to #{@running.size} running processes...")
@running.each_value do |fiber|
fiber.resume(Terminate)
end
end