Class: Actor::Messaging::Read::Substitute

Inherits:
Object
  • Object
show all
Defined in:
lib/actor/messaging/read/substitute.rb

Constant Summary collapse

WouldWait = 
Class.new StandardError

Instance Method Summary collapse

Instance Method Details

#add_message(message) ⇒ Object 



19
20
21
 
# File 'lib/actor/messaging/read/substitute.rb', line 19

def add_message message
  messages << message
end

#call(wait: nil) ⇒ Object 



5
6
7
8
9
10
11
12
13
 
# File 'lib/actor/messaging/read/substitute.rb', line 5

def call wait: nil
  message = messages.shift

  if message.nil? and wait
    raise WouldWait
  end

  message
end

#messages ⇒ Object 



23
24
25
 
# File 'lib/actor/messaging/read/substitute.rb', line 23

def messages
  @messages ||= []
end

#messages_available? ⇒ Boolean

Returns:

  • (Boolean) 


15
16
17
 
# File 'lib/actor/messaging/read/substitute.rb', line 15

def messages_available?
  messages.any?
end