Class: Celluloid::Receivers

Inherits:
Object show all
Defined in:
lib/vendor/celluloid/lib/celluloid/receivers.rb

Overview

Allow methods to directly interact with the actor protocol

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Receivers

Returns a new instance of Receivers.



6
7
8
9
 
# File 'lib/vendor/celluloid/lib/celluloid/receivers.rb', line 6

def initialize
  @receivers = Set.new
  @timers = Timers.new
end

Instance Method Details

#fire_timers ⇒ Object

Fire any pending timers



32
33
34
 
# File 'lib/vendor/celluloid/lib/celluloid/receivers.rb', line 32

def fire_timers
  @timers.fire
end

#handle_message(message) ⇒ Object

Handle incoming messages



37
38
39
40
41
42
43
44
 
# File 'lib/vendor/celluloid/lib/celluloid/receivers.rb', line 37

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(timeout = nil, &block) ⇒ Object

Receive an asynchronous message



12
13
14
15
16
17
18
19
20
21
22
23
24
 
# File 'lib/vendor/celluloid/lib/celluloid/receivers.rb', line 12

def receive(timeout = nil, &block)
  receiver = Receiver.new block

  if timeout
    receiver.timer = @timers.add(timeout) do
      @receivers.delete receiver
      receiver.resume
    end
  end

  @receivers << receiver
  Task.suspend
end

#wait_interval ⇒ Object

How long to wait until the next timer fires



27
28
29
 
# File 'lib/vendor/celluloid/lib/celluloid/receivers.rb', line 27

def wait_interval
  @timers.wait_interval
end