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