class Piperun::Filters::ParallelFilter

Attributes

pipelines[R]

Public Class Methods

new(&block) click to toggle source
Calls superclass method Piperun::Filters::Filter::new
# File lib/piperun/filters/parallel_filter.rb, line 5
def initialize(&block)
  super()

  @pipelines = []

  dsl = DSL.new(self)
  dsl.instance_eval(&block)
end

Public Instance Methods

add_pipeline(p) click to toggle source
# File lib/piperun/filters/parallel_filter.rb, line 14
def add_pipeline(p)
  @pipelines << p
end
run(src, dst, files) click to toggle source
# File lib/piperun/filters/parallel_filter.rb, line 18
def run(src, dst, files)
  outfiles = []
  @pipelines.each do |p|
    outfiles |= Piperun::Pipeline.build(src, dst, &p).run(files)
  end
  return outfiles
end