lib/celluloid/zmq/mailbox.rb in celluloid-zmq-0.0.3 vs lib/celluloid/zmq/mailbox.rb in celluloid-zmq-0.0.4

- old
+ new

@@ -1,12 +1,13 @@ module Celluloid module ZMQ # A Celluloid mailbox for Actors that wait on 0MQ sockets class Mailbox < Celluloid::IO::Mailbox def initialize + # More APIs and less monkeypatching would be useful here @messages = [] - @lock = Mutex.new - @waker = Celluloid::ZMQ::Waker.new + @lock = Mutex.new + @waker = Waker.new @reactor = Reactor.new(@waker) end end end end