diff --git a/Gemfile.lock b/Gemfile.lock index c97e6ca..16df641 100644 --- a/Gemfile.lock +++ b/Gemfile.lock @@ -1,7 +1,7 @@ PATH remote: . specs: - redis_stream (0.1.3) + redis_stream (0.1.4) GEM remote: https://rubygems.org/ diff --git a/spec/dummy_redis.rb b/spec/dummy_redis.rb index c35a81a..4fa75e6 100644 --- a/spec/dummy_redis.rb +++ b/spec/dummy_redis.rb @@ -8,7 +8,7 @@ def xadd(stream, data, approximate: nil, maxlen: nil, nomkstream: nil, id: "*") @streams[stream] << data end - def xreadgroup(group, consumer, streams, condition, count: 1, block: 5000) + def xreadgroup(group, consumer, streams, condition, count: 1, block: 5000, noack: false) @streams[streams] ||= [] @streams[streams].map.with_index do |data, index| [streams, {index => data}]