Sha256: 2aebd73f6b2ed2626171e8e1a52e16071a5ac658077852aa96cf497bee4889df

Contents?: true

Size: 518 Bytes

Versions: 5

Compression:

Stored size: 518 Bytes

Contents

module ActiveGraph
  module Node
    module Query
      module QueryProxyFindInBatches
        def find_in_batches(options = {})
          query.return(identity).find_in_batches(identity, @model.primary_key, options) do |batch|
            yield batch.map(&identity)
          end
        end

        def find_each(options = {})
          query.return(identity).find_each(identity, @model.primary_key, options) do |result|
            yield result.send(identity)
          end
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version Path
activegraph-10.0.0.pre.beta.5 lib/active_graph/node/query/query_proxy_find_in_batches.rb
activegraph-10.0.0.pre.beta.4 lib/active_graph/node/query/query_proxy_find_in_batches.rb
activegraph-10.0.0.pre.beta.3 lib/active_graph/node/query/query_proxy_find_in_batches.rb
activegraph-10.0.0.pre.beta.2 lib/active_graph/node/query/query_proxy_find_in_batches.rb
activegraph-10.0.0.pre.beta.1 lib/active_graph/node/query/query_proxy_find_in_batches.rb