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