lib/polyphony/core/supervisor.rb in polyphony-0.27 vs lib/polyphony/core/supervisor.rb in polyphony-0.28

- old
+ new

@@ -8,9 +8,10 @@ # Implements a supervision mechanism for controlling multiple fibers class Supervisor def initialize @fibers = [] @pending = {} + yield(self) if block_given? end def await(&block) @mode = :await @supervisor_fiber = Fiber.current