(self, r)
| 6341 | |
| 6342 | @skip_if_server_version_lt("6.2.0") |
| 6343 | def test_xadd_nomkstream(self, r): |
| 6344 | # nomkstream option |
| 6345 | stream = "stream" |
| 6346 | r.xadd(stream, {"foo": "bar"}) |
| 6347 | r.xadd(stream, {"some": "other"}, nomkstream=False) |
| 6348 | assert r.xlen(stream) == 2 |
| 6349 | r.xadd(stream, {"some": "other"}, nomkstream=True) |
| 6350 | assert r.xlen(stream) == 3 |
| 6351 | |
| 6352 | @skip_if_server_version_lt("6.2.0") |
| 6353 | def test_xadd_minlen_and_limit(self, r): |