Sha256: 9ffe29c66ee7c564520e6f47e8738e06298f4b3e6f1e22882b65060dc882cb2c
Contents?: true
Size: 599 Bytes
Versions: 17
Compression:
Stored size: 599 Bytes
Contents
require 'job_uniqueness/spec_helper'
RSpec.describe CanvasSync::JobUniqueness::Strategy::UntilExecuted do
include_context 'lock strategy specs', strategy: :until_executed
include_examples "a lock implementation"
describe "#on_enqueue" do
it "locks the queue" do
process_one.on_enqueue {}
expect(process_one).to be_locked
end
end
describe "#on_perform" do
it "unlocks after processing" do
process_one.on_enqueue {}
process_one.on_perform {}
process_one.batch_callback(:success, nil)
expect(process_one).to_not be_locked
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems