class Trailblazer::Activity::TaskWrap::Pipeline::Merge

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

{Extension} API

Public Class Methods

new(*extension_rows) click to toggle source
# File lib/trailblazer/activity/task_wrap/pipeline.rb, line 44
def initialize(*extension_rows)
  @extension_rows = extension_rows
end

Public Instance Methods

call(task_wrap_pipeline) click to toggle source
# 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