lib/celluloid/zmq/mailbox.rb in celluloid-zmq-0.0.1 vs lib/celluloid/zmq/mailbox.rb in celluloid-zmq-0.0.2
- old
+ new
@@ -3,11 +3,11 @@
# A Celluloid mailbox for Actors that wait on 0MQ sockets
class Mailbox < Celluloid::IO::Mailbox
def initialize
@messages = []
@lock = Mutex.new
- @waker = Celluloid::IO::Waker.new
+ @waker = Celluloid::ZMQ::Waker.new
@reactor = Reactor.new(@waker)
end
end
end
-end
\ No newline at end of file
+end