lib/searchkick/reindex_queue.rb in searchkick-4.5.1 vs lib/searchkick/reindex_queue.rb in searchkick-4.5.2

- old
+ new

@@ -13,10 +13,10 @@ end # TODO use reliable queuing def reserve(limit: 1000) if supports_rpop_with_count? - Searchkick.with_redis { |r| r.call("rpop", redis_key, limit) } + Searchkick.with_redis { |r| r.call("rpop", redis_key, limit) }.to_a else record_ids = [] Searchkick.with_redis do |r| while record_ids.size < limit && (record_id = r.rpop(redis_key)) record_ids << record_id