diff options
Diffstat (limited to 'tests/test_commands.py')
| -rw-r--r-- | tests/test_commands.py | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/tests/test_commands.py b/tests/test_commands.py index ab9c9c9..997d928 100644 --- a/tests/test_commands.py +++ b/tests/test_commands.py @@ -1756,6 +1756,22 @@ class TestStrictCommands(object): assert sr.xdel(stream_name, 1, stamp) == 1 assert sr.xdel(stream_name, 1, stamp, 42) == 0 + @skip_if_server_version_lt('5.0.0') + def test_strict_xtrim(self, sr): + stream_name = 'xtrim_test_stream' + sr.delete(stream_name) + + assert sr.xtrim(stream_name, 1000) == 0 + + for i in range(300): + sr.xadd(stream_name, index=i) + + assert sr.xtrim(stream_name, 1000, approximate=False) == 0 + assert sr.xtrim(stream_name, 300) == 0 + assert sr.xtrim(stream_name, 299) == 0 + assert sr.xtrim(stream_name, 234) == 0 + assert sr.xtrim(stream_name, 234, approximate=False) == 66 + def test_strict_zadd(self, sr): sr.zadd('a', 1.0, 'a1', 2.0, 'a2', a3=3.0) assert sr.zrange('a', 0, -1, withscores=True) == \ |