Class: Actor::Messaging::Read
- Inherits:
-
Object
- Object
- Actor::Messaging::Read
- Defined in:
- lib/actor/messaging/read.rb,
lib/actor/messaging/read/assertions.rb,
lib/actor/messaging/read/dependency.rb,
lib/actor/messaging/read/substitute.rb
Direct Known Subclasses
Defined Under Namespace
Modules: Assertions, Dependency Classes: Substitute
Instance Attribute Summary collapse
-
#queue ⇒ Object
readonly
Returns the value of attribute queue.
Class Method Summary collapse
Instance Method Summary collapse
- #call(wait: nil) ⇒ Object
-
#initialize(queue) ⇒ Read
constructor
A new instance of Read.
Constructor Details
#initialize(queue) ⇒ Read
Returns a new instance of Read.
6 7 8 |
# File 'lib/actor/messaging/read.rb', line 6 def initialize queue @queue = queue end |
Instance Attribute Details
#queue ⇒ Object (readonly)
Returns the value of attribute queue.
4 5 6 |
# File 'lib/actor/messaging/read.rb', line 4 def queue @queue end |
Class Method Details
.build(address) ⇒ Object
10 11 12 13 14 |
# File 'lib/actor/messaging/read.rb', line 10 def self.build address queue = address.queue new queue end |
.call(address, wait: nil) ⇒ Object
16 17 18 19 20 |
# File 'lib/actor/messaging/read.rb', line 16 def self.call address, wait: nil instance = build address instance.(wait: wait) end |
Instance Method Details
#call(wait: nil) ⇒ Object
22 23 24 25 26 27 28 29 |
# File 'lib/actor/messaging/read.rb', line 22 def call wait: nil non_block = wait == false queue.deq non_block rescue ThreadError return nil end |