Module: Turbine::Pipeline

Defined in:
lib/turbine/pipeline/dsl.rb,
lib/turbine/pipeline/pump.rb,
lib/turbine/pipeline/split.rb,
lib/turbine/pipeline/trace.rb,
lib/turbine/pipeline/filter.rb,
lib/turbine/pipeline/sender.rb,
lib/turbine/pipeline/unique.rb,
lib/turbine/pipeline/journal.rb,
lib/turbine/pipeline/segment.rb,
lib/turbine/pipeline/expander.rb,
lib/turbine/pipeline/transform.rb,
lib/turbine/pipeline/traversal.rb,
lib/turbine/pipeline/journal_filter.rb

Defined Under Namespace

Classes: Also, DSL, Expander, Filter, Journal, JournalFilter, Pump, Segment, Sender, Split, Trace, Transform, Traverse, Unique

Class Method Summary collapse

Class Method Details

.dsl(source) ⇒ Object

Public: Starts a new Pipeline chain using the given source as the source.

source - An object, or array of objects, which will be iterated through

the pipeline.

Returns a DSL.



10
11
12
 
# File 'lib/turbine/pipeline/dsl.rb', line 10

def self.dsl(source)
  DSL.new(Pump.new(Array(source)))
end