Contents

module Celluloid
  module Internals
    # Event signaling between methods of the same object
    class Signals
      def initialize
        @conditions = {}
      end

      # Wait for the given signal and return the associated value
      def wait(name)
        raise "cannot wait for signals while exclusive" if Celluloid.exclusive?

        @conditions[name] ||= Condition.new
        @conditions[name].wait
      end

      # Send a signal to all method calls waiting for the given name
      def broadcast(name, value = nil)
        condition = @conditions.delete(name)
        condition.broadcast(value) if condition
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 2 rubygems

Version	Path
celluloid-0.18.0	lib/celluloid/internals/signals.rb
celluloid-0.18.0.pre2	lib/celluloid/internals/signals.rb
celluloid-essentials-0.20.0.pre14	lib/celluloid/internals/signals.rb
celluloid-essentials-0.20.0.pre13	lib/celluloid/internals/signals.rb
celluloid-essentials-0.20.0.pre12	lib/celluloid/internals/signals.rb