Method: Resque::Reports::Common::BatchedReport#data_each

Defined in:
lib/resque/reports/common/batched_report.rb

#data_each(force = false) ⇒ Object

Internal: Выполняет запрос отчета пачками и выполняет block для каждой пачки

Переопредленный метод из Resque::Reports

Returns Nothing



23
24
25
26
27
28
29
 
# File 'lib/resque/reports/common/batched_report.rb', line 23

def data_each(force = false)
  0.step(data_size, batch_size) do |batch_offset|
    connection.execute(batched_query(batch_offset)).each do |element|
      yield element
    end
  end
end