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|
          handle_value 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.2.1	lib/stages/each.rb
stages-1.2.0	lib/stages/each.rb
stages-1.1.5	lib/stages/each.rb
stages-1.1.2	lib/stages/each.rb