module Tengine::Job::Runtime::Signal::Transmittable

Public Instance Methods

activate(signal) click to toggle source
# File lib/tengine/job/runtime/signal.rb, line 191
def activate(signal); raise NotImplementedError; end
complete_origin_edge(signal, options = {}) click to toggle source
# File lib/tengine/job/runtime/signal.rb, line 193
def complete_origin_edge(signal, options = {})
  origin_edge = signal.cache(signal.paths.last)
  origin_edge ||= signal.cache(prev_edges.first)
  begin
    return if options[:except_closed] && origin_edge.closed?
    origin_edge.complete(signal)
  rescue Exception => e
    puts "[#{e.class.name}] #{e.message}\nsignal.paths: #{@paths.inspect}"
    raise e
  end
end
transmit(signal) click to toggle source

includeするモジュールは以下のメソッドを定義しなければならない

# File lib/tengine/job/runtime/signal.rb, line 190
def transmit(signal); raise NotImplementedError; end