Contents

module Stages
  class Splice < Stage
    def initialize(*args, &block)
      @pipelines = args
      super()
    end

    def process
      @pipelines.each do |pipeline|
        pipeline.each do |item|
          handle_value item
        end
      end
      super()
    end

    def reset
      @pipelines.each{ |pipeline| pipeline.reset }
      super()
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
stages-1.2.1	lib/stages/splice.rb
stages-1.2.0	lib/stages/splice.rb
stages-1.1.5	lib/stages/splice.rb