lib/celluloid/receivers.rb in celluloid-0.13.0 vs lib/celluloid/receivers.rb in celluloid-0.14.0.pre
- old
+ new
@@ -10,10 +10,10 @@
end
# Receive an asynchronous message
def receive(timeout = nil, &block)
if Celluloid.exclusive?
- Thread.mailbox.receive(timeout, &block)
+ Celluloid.mailbox.receive(timeout, &block)
else
receiver = Receiver.new block
if timeout
receiver.timer = @timers.after(timeout) do