Module: PiecePipe

Defined in:: lib/piece_pipe/step.rb,
lib/piece_pipe/version.rb,
lib/piece_pipe/map_step.rb,
lib/piece_pipe/pipeline.rb,
lib/piece_pipe/tap_step.rb,
lib/piece_pipe/collector.rb,
lib/piece_pipe/debug_step.rb,
lib/piece_pipe/method_step.rb,
lib/piece_pipe/assembly_step.rb,
lib/piece_pipe/group_by_step.rb,
lib/piece_pipe/hashed_aggregator.rb,
lib/piece_pipe/method_assembly_step.rb

Defined Under Namespace

Classes: AssemblyStep, Collector, DebugStep, GroupByStep, HashedAggregator, MapStep, MethodAssemblyStep, MethodStep, Pipeline, Step, TapStep

Constant Summary collapse

VERSION =

"0.2.1"

Instance Method Summary collapse

#create_pipeline ⇒ Object

Instance Method Details

#create_pipeline ⇒ `Object`



77
78
79

# File 'lib/piece_pipe/pipeline.rb', line 77

def create_pipeline
  ::Pipeline::Pipeline.new
end