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