Contents

module Stages
  class Limit < Stage
    def initialize(allowed)
      @allowed = allowed
      @sent = 0
      super()
    end

    def process
      while @sent < @allowed
        handle_value input
        @sent += 1
      end
    end

     def reset
       @sent = 0
       super()
     end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
stages-1.2.1	lib/stages/limit.rb
stages-1.2.0	lib/stages/limit.rb
stages-1.1.5	lib/stages/limit.rb
stages-1.1.2	lib/stages/limit.rb
stages-1.1.1	lib/stages/limit.rb