lib/searchkick/reindex_queue.rb in searchkick-2.5.0 vs lib/searchkick/reindex_queue.rb in searchkick-3.0.0
- old
+ new
@@ -13,10 +13,10 @@
end
# TODO use reliable queuing
def reserve(limit: 1000)
record_ids = Set.new
- while record_ids.size < limit && record_id = Searchkick.with_redis { |r| r.rpop(redis_key) }
+ while record_ids.size < limit && (record_id = Searchkick.with_redis { |r| r.rpop(redis_key) })
record_ids << record_id
end
record_ids.to_a
end