Contents

class TestEventedMailbox < Celluloid::Mailbox::Evented
  class Reactor
    def initialize
      @condition = ConditionVariable.new
      @mutex = Mutex.new
    end

    def wakeup
      @mutex.synchronize do
        @condition.signal
      end
    end

    def run_once(timeout)
      @mutex.synchronize do
        @condition.wait(@mutex, timeout)
      end
    end

    def shutdown
    end
  end

  def initialize
    super(Reactor)
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
celluloid-0.17.4	spec/support/examples/evented_mailbox_class.rb
celluloid-0.18.0.pre	spec/support/examples/evented_mailbox_class.rb
celluloid-0.17.3	spec/support/examples/evented_mailbox_class.rb
celluloid-0.17.2	spec/support/examples/evented_mailbox_class.rb
celluloid-0.17.1.2	spec/support/examples/evented_mailbox_class.rb
celluloid-0.17.1.1	spec/support/examples/evented_mailbox_class.rb
celluloid-0.17.1	spec/support/examples/evented_mailbox_class.rb
celluloid-0.17.0	spec/support/examples/evented_mailbox_class.rb