Class: Trailblazer::Activity::TaskWrap::Pipeline::Merge

Inherits:
Object
  • Object
show all
Defined in:
lib/trailblazer/activity/task_wrap/pipeline.rb

Overview

Merges extension_rows into the task_wrap_pipeline. This is usually used in step extensions or at runtime for wrap_runtime.

Extension API

Instance Method Summary collapse

Constructor Details

#initialize(*extension_rows) ⇒ Merge

TODO: RENAME TO TaskWrap::Extension(::Merge)



44
45
46
 
# File 'lib/trailblazer/activity/task_wrap/pipeline.rb', line 44

def initialize(*extension_rows)
  @extension_rows = extension_rows
end

Instance Method Details

#call(task_wrap_pipeline) ⇒ Object 



48
49
50
51
 
# File 'lib/trailblazer/activity/task_wrap/pipeline.rb', line 48

def call(task_wrap_pipeline)
  @extension_rows.collect { |(insert_function, target_id, row)| task_wrap_pipeline = insert_function.(task_wrap_pipeline, target_id, row) }
  task_wrap_pipeline
end