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