spec/sidekiq/merger/merge_spec.rb in sidekiq-merger-0.0.4 vs spec/sidekiq/merger/merge_spec.rb in sidekiq-merger-0.0.5
- old
+ new
@@ -61,31 +61,31 @@
end
end
describe "#add" do
it "adds the args in lazy merge" do
- expect(redis).to receive(:push).with("name:queue:foo", [1, 2, 3], execution_time)
+ expect(redis).to receive(:push_message).with("name:queue:foo", [1, 2, 3], execution_time)
subject.add([1, 2, 3], execution_time)
end
context "with unique option" do
let(:options) { { key: -> (args) { args.to_json }, unique: true } }
it "adds the args in lazy merge" do
- expect(redis).to receive(:push).with("name:queue:foo", [1, 2, 3], execution_time)
+ expect(redis).to receive(:push_message).with("name:queue:foo", [1, 2, 3], execution_time)
subject.add([1, 2, 3], execution_time)
end
context "the args has alredy been added" do
before { subject.add([1, 2, 3], execution_time) }
it "adds the args in lazy merge" do
- expect(redis).not_to receive(:push)
+ expect(redis).not_to receive(:push_message)
subject.add([1, 2, 3], execution_time)
end
end
end
end
describe "#delete" do
it "adds the args in lazy merge" do
- expect(redis).to receive(:delete).with("name:queue:foo", [1, 2, 3])
+ expect(redis).to receive(:delete_message).with("name:queue:foo", [1, 2, 3])
subject.delete([1, 2, 3])
end
end
describe "#size" do