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