class Dynflow::Actor
Common parent for all the Dynflow actors defining some defaults that we preffer here.
Public Instance Methods
behaviour_definition()
click to toggle source
# File lib/dynflow/actor.rb, line 141 def behaviour_definition [*Concurrent::Actor::Behaviour.base(:just_log), Concurrent::Actor::Behaviour::Buffer, [SetResultsWithOriginLogging, :just_log], Concurrent::Actor::Behaviour::Awaits, PoliteTermination, Concurrent::Actor::Behaviour::ExecutesContext, Concurrent::Actor::Behaviour::ErrorsOnUnknownMessage] end
finish_termination()
click to toggle source
# File lib/dynflow/actor.rb, line 132 def finish_termination @terminated.fulfill(true) reference.tell(:terminate!) end
start_termination(future)
click to toggle source
# File lib/dynflow/actor.rb, line 128 def start_termination(future) @terminated = future end
terminating?()
click to toggle source
# File lib/dynflow/actor.rb, line 137 def terminating? !!@terminated end