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
on_envelope(envelope)
click to toggle source
# File lib/concurrent/actor/behaviour/awaits.rb, line 11 def on_envelope(envelope) if envelope.message == :await true else pass envelope end end