Object
Allow methods to directly interact with the actor protocol
Fire any pending timers
# File lib/celluloid/receivers.rb, line 37 def fire_timers @timers.fire end
Handle incoming messages
# File lib/celluloid/receivers.rb, line 42 def handle_message(message) receiver = @receivers.find { |r| r.match(message) } return unless receiver @receivers.delete receiver @timers.cancel receiver.timer if receiver.timer receiver.resume message end
Receive an asynchronous message
# File lib/celluloid/receivers.rb, line 13 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.