Module: Actor::Messaging::Read::Assertions
- Defined in:
- lib/actor/messaging/read/assertions.rb
Instance Method Summary collapse
Instance Method Details
#address?(address) ⇒ Boolean
5 6 7 |
# File 'lib/actor/messaging/read/assertions.rb', line 5 def address? address queue? address.queue end |
#next_message?(message) ⇒ Boolean
9 10 11 12 13 14 15 16 17 |
# File 'lib/actor/messaging/read/assertions.rb', line 9 def begin = @queue.deq true rescue ThreadError return false end == end |
#queue?(queue) ⇒ Boolean
19 20 21 |
# File 'lib/actor/messaging/read/assertions.rb', line 19 def queue? queue self.queue == queue end |