Contents

class Germinate::Pipeline
  attr_reader :processes

  def initialize(processes)
    @processes = processes
  end

  def call(input)
    @processes.inject(input) { |output, process|
      process.call(output)
    }
  end
end

Version data entries

2 entries across 2 versions & 2 rubygems

Version	Path
devver-germinate-1.2.0	lib/germinate/pipeline.rb
germinate-1.2.0	lib/germinate/pipeline.rb