Skip to content

Commit 5585b67

Browse files
committed
Fix streams_test suite
1 parent 444e219 commit 5585b67

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

test/streams_test.rb

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,10 +9,10 @@ def test_read_a_trimmed_entry
99
r.xgroup(:create, 'k1', 'g1', '0', mkstream: true)
1010
entry_id = r.xadd('k1', { value: 'v1' })
1111

12-
assert_equal r.xreadgroup('g1', 'c1', 'k1', '>'), { 'k1' => [[entry_id, { 'value' => 'v1' }]] }
13-
assert_equal r.xreadgroup('g1', 'c1', 'k1', '0'), { 'k1' => [[entry_id, { 'value' => 'v1' }]] }
12+
assert_equal({ 'k1' => [[entry_id, { 'value' => 'v1' }]] }, r.xreadgroup('g1', 'c1', 'k1', '>'))
13+
assert_equal({ 'k1' => [[entry_id, { 'value' => 'v1' }]] }, r.xreadgroup('g1', 'c1', 'k1', '0'))
1414
r.xtrim('k1', 0)
1515

16-
assert_equal r.xreadgroup('g1', 'c1', 'k1', '0'), { 'k1' => [[entry_id, { 'value' => nil }]] }
16+
assert_equal({ 'k1' => [[entry_id, nil]] }, r.xreadgroup('g1', 'c1', 'k1', '0'))
1717
end
1818
end

0 commit comments

Comments
 (0)