method
pipeline_entries
v7.1.3.2 -
Show latest stable
- Class:
ActiveSupport::Cache::RedisCacheStore
pipeline_entries(entries, &block)private
No documentation available.
# File activesupport/lib/active_support/cache/redis_cache_store.rb, line 300
def pipeline_entries(entries, &block)
redis.then { |c|
if c.is_a?(Redis::Distributed)
entries.group_by { |k, _v| c.node_for(k) }.each do |node, sub_entries|
node.pipelined { |pipe| yield(pipe, sub_entries) }
end
else
c.pipelined { |pipe| yield(pipe, entries) }
end
}
end