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