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
-