class Concurrent::Actor::Behaviour::Awaits
Accepts ‘:await` messages. Which allows to wait on Actor
to process all previously send messages.
actor << :a << :b actor.ask(:await).wait # blocks until :a and :b are processed
Public Instance Methods
Source
# File lib/concurrent-ruby-edge/concurrent/actor/behaviour/awaits.rb, line 13 def on_envelope(envelope) if envelope.message == :await true else pass envelope end end