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 46
def behaviour_definition
  [*Concurrent::Actor::Behaviour.base(:just_log),
   Concurrent::Actor::Behaviour::Buffer,
   [Concurrent::Actor::Behaviour::SetResults, :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 37
def finish_termination
  @terminated.fulfill(true)
  reference.tell(:terminate!)
end
start_termination(future) click to toggle source
# File lib/dynflow/actor.rb, line 33
def start_termination(future)
  @terminated = future
end
terminating?() click to toggle source
# File lib/dynflow/actor.rb, line 42
def terminating?
  !!@terminated
end