diff --git a/lib/redis.rb b/lib/redis.rb index 7fb367057..c2af65be8 100644 --- a/lib/redis.rb +++ b/lib/redis.rb @@ -3423,7 +3423,12 @@ def method_missing(command, *args) # rubocop:disable Style/MissingRespondToMissi end } + EMPTY_STREAM_RESPONSE = [nil].freeze + private_constant :EMPTY_STREAM_RESPONSE + HashifyStreamEntries = lambda { |reply| + return [] if reply == EMPTY_STREAM_RESPONSE + reply.map do |entry_id, values| [entry_id, values.each_slice(2).to_h] end