Allows to pause actors on errors. When paused all arriving messages are collected and processed after the actor is resumed or reset. Resume will simply continue with next message. Reset also reinitialized context. @note TODO missing example
# File lib/concurrent/actor/behaviour/pausing.rb, line 21 def on_envelope(envelope) case envelope.message when :pause! pause! when :paused? paused? when :resume! resume! when :reset! reset! when :restart! restart! else if paused? @deferred << envelope MESSAGE_PROCESSED else pass envelope end end end
# File lib/concurrent/actor/behaviour/pausing.rb, line 72 def on_event(public, event) event_name, _ = event reject_deferred if event_name == :terminated super public, event end
# File lib/concurrent/actor/behaviour/pausing.rb, line 43 def pause!(error = nil) do_pause broadcast true, error || :paused true end
# File lib/concurrent/actor/behaviour/pausing.rb, line 17 def paused? @paused end
# File lib/concurrent/actor/behaviour/pausing.rb, line 56 def reset! return false unless paused? broadcast(false, :resetting) do_reset broadcast(true, :reset) true end
Generated with the Darkfish Rdoc Generator 2.