Module: Tengine::Job::Signal::Transmittable

Included in:
Edge, Vertex
Defined in:
lib/tengine/job/signal.rb

Instance Method Summary collapse

Instance Method Details

#activate(signal) ⇒ Object

Raises:

  • (NotImplementedError) 


106
 
# File 'lib/tengine/job/signal.rb', line 106

def activate(signal); raise NotImplementedError; end

#complete_origin_edge(signal, options = {}) ⇒ Object 



108
109
110
111
112
113
114
115
116
117
118
 
# File 'lib/tengine/job/signal.rb', line 108

def complete_origin_edge(signal, options = {})
  origin_edge = signal.paths.last
  origin_edge ||= 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) ⇒ Object

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

Raises:

  • (NotImplementedError) 


105
 
# File 'lib/tengine/job/signal.rb', line 105

def transmit(signal); raise NotImplementedError; end