Method: Wukong::DriverMethods#finalize_and_stop_dataflow

Defined in:
lib/wukong/driver.rb

#finalize_and_stop_dataflow ⇒ Object

Works similar to #finalize_dataflow but calls Processor#stop after calling Processor#finalize on each processor.



138
139
140
141
142
143
144
145
 
# File 'lib/wukong/driver.rb', line 138

def finalize_and_stop_dataflow
  finalize
  dataflow.each_stage do |stage|
    stage.finalize(&wiring.advance(stage))
    stage.stop
  end
  stop
end