Contents

module Stages
  class Each < Stage
    def initialize(things = nil, &block)
      @things = things unless things.nil?
      @block = block
      super()
    end

    def process
      if @things
        process_things
      else
        process_inputs
      end
    end

    def process_inputs
      while !source_empty?
        v = input
        v = @block.call(v) if @block
        v.each do |v|
          output v
        end
      end
    end

    def process_things
      @things = @block.call(@things) if @block
      @things.each do |thing|
        handle_value thing
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
stages-1.0.1	lib/stages/each.rb
stages-1.0.0	lib/stages/each.rb
stages-0.4.1	lib/stages/each.rb
stages-0.4.0	lib/stages/each.rb