Method: ThreadedPipeline#initialize

Defined in:
lib/threaded_pipeline.rb

#initialize(discard_results: false) ⇒ ThreadedPipeline

Returns a new instance of ThreadedPipeline.



34
35
36
37
38
 
# File 'lib/threaded_pipeline.rb', line 34

def initialize(discard_results: false)
  @stages = []
  @started = false
  @discard_results = discard_results
end