in elasticsearch-model/lib/elasticsearch/model/adapters/active_record.rb [91:105]
def __find_in_batches(options={}, &block)
query = options.delete(:query)
named_scope = options.delete(:scope)
preprocess = options.delete(:preprocess)
scope = self
scope = scope.__send__(named_scope) if named_scope
scope = scope.instance_exec(&query) if query
scope.find_in_batches(**options) do |batch|
batch = self.__send__(preprocess, batch) if preprocess
yield(batch) if batch.present?
end
end