Skip to content

Commit 8aa62f7

Browse files
committed
fix
1 parent 4348f57 commit 8aa62f7

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

test/redis_client/test_cluster.rb

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -722,6 +722,8 @@ def test_stream_commands
722722
got = consumer.call('xread', 'streams', '{stream}1', '{stream}2', '0', '0')
723723
consumer.close
724724

725+
got = got.to_h if TEST_REDIS_MAJOR_VERSION < 6
726+
725727
assert_equal('foo', got.fetch('{stream}1')[0][1][1])
726728
assert_equal('bar', got.fetch('{stream}1')[1][1][1])
727729
assert_equal('baz', got.fetch('{stream}2')[0][1][1])
@@ -741,6 +743,11 @@ def test_stream_group_commands
741743
consumer1.close
742744
consumer2.close
743745

746+
if TEST_REDIS_MAJOR_VERSION < 6
747+
got1 = got1.to_h
748+
got2 = got2.to_h
749+
end
750+
744751
assert_equal('data1', got1.fetch('{stream}1')[0][1][1])
745752
assert_equal('data2', got2.fetch('{stream}1')[0][1][1])
746753
end

0 commit comments

Comments
 (0)