Class: Plumbing::Actor::Threaded::Message

Inherits:

Actor::Message

• Object
• Actor::Message
• Plumbing::Actor::Threaded::Message

Defined in:

lib/plumbing/actor/threaded.rb

Instance Method Summary

• #_wait_until_ready ⇒ Object

  blocks until deliver closes it.

• #deliver ⇒ Object

Instance Method Details

#_wait_until_ready ⇒ Object

blocks until deliver closes it

# File 'lib/plumbing/actor/threaded.rb', line 68

def _wait_until_ready = @ready.pop # blocks until deliver closes it

#deliver ⇒ Object

# File 'lib/plumbing/actor/threaded.rb', line 62

def deliver
  super
ensure
  @ready.close # wakes the awaiting thread
end