Class: Piperun::Filters::ParallelFilter

Inherits:
Filter
  • Object
show all
Defined in:
lib/piperun/filters/parallel_filter.rb

Defined Under Namespace

Classes: DSL

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(&block) ⇒ ParallelFilter

Returns a new instance of ParallelFilter.



5
6
7
8
9
10
11
12
 
# File 'lib/piperun/filters/parallel_filter.rb', line 5

def initialize(&block)
  super()

  @pipelines = []

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

Instance Attribute Details

#pipelines ⇒ Object (readonly)

Returns the value of attribute pipelines.



3
4
5
 
# File 'lib/piperun/filters/parallel_filter.rb', line 3

def pipelines
  @pipelines
end

Instance Method Details

#add_pipeline(p) ⇒ Object 



14
15
16
 
# File 'lib/piperun/filters/parallel_filter.rb', line 14

def add_pipeline(p)
  @pipelines << p
end

#run(src, dst, files) ⇒ Object 



18
19
20
21
22
23
24
 
# 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