spec/redstream/producer_spec.rb in redstream-0.0.1 vs spec/redstream/producer_spec.rb in redstream-0.1.0

- old
+ new

@@ -1,6 +1,5 @@ - require File.expand_path("../spec_helper", __dir__) RSpec.describe Redstream::Producer do describe "#queue" do it "adds a queue message for individual objects" do @@ -64,16 +63,15 @@ { "payload" => JSON.dump(products[1].redstream_payload) } ]) end it "should resepect wait for delay" do - product = create(:product) + create(:product) stream_key_name = Redstream.stream_key_name("products.delay") products = create_list(:product, 2) expect { Redstream::Producer.new(wait: 0).bulk_delay(products) }.to change { redis.xlen(stream_key_name) }.by(2) end end end -