Sha256: 1b07283973d5576d64a60572c2054230e78c4ed57c44be7abe36201c725ce1a5
Contents?: true
Size: 296 Bytes
Versions: 14
Compression:
Stored size: 296 Bytes
Contents
module SidekiqUniqueJobs
module Lock
class UntilAndWhileExecuting < UntilExecuting
def execute(callback)
lock = WhileExecuting.new(item, redis_pool)
lock.synchronize do
callback.call if unlock(:server)
yield
end
end
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems