Allow methods to directly interact with the actor protocol
Handle incoming messages
# File lib/celluloid/receivers.rb, line 33 def handle_message(message) receiver = @receivers.find { |r| r.match(message) } return unless receiver @receivers.delete receiver receiver.timer.cancel if receiver.timer receiver.resume message message end
Receive an asynchronous message
# File lib/celluloid/receivers.rb, line 14 def receive(timeout = nil, &block) if Celluloid.exclusive? Celluloid.mailbox.receive(timeout, &block) else receiver = Receiver.new block if timeout receiver.timer = @timers.after(timeout) do @receivers.delete receiver receiver.resume end end @receivers << receiver Task.suspend :receiving end end
Generated with the Darkfish Rdoc Generator 2.