.rb

  def each(opts={}) #todo(tx=nil)
    TinyDS::LowDS.retry_if_timeout do
      index = 0
      @q.each(opts.dup) do |entity| # <= HERE
        if opts[:limit] && opts[:limit]<=index
          TinyDS::Base.logger.warn "too_many_results: each limit=#{opts[:limit]} index=#{index}"
          break
        end
        index += 1
        yield(@model_class.new_from_entity(entity))
      end
    end
  end

gistfile2.txt