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