(self, r)
| 6846 | |
| 6847 | @skip_if_server_version_lt("8.7.2") |
| 6848 | def test_xnack_silent(self, r): |
| 6849 | stream = "stream" |
| 6850 | group = "group" |
| 6851 | consumer = "consumer" |
| 6852 | m1 = r.xadd(stream, {"foo": "bar"}) |
| 6853 | m2 = r.xadd(stream, {"foo": "bar"}) |
| 6854 | r.xgroup_create(stream, group, 0) |
| 6855 | r.xreadgroup(group, consumer, streams={stream: ">"}) |
| 6856 | # SILENT mode returns count of NACKed messages |
| 6857 | result = r.xnack(stream, group, "SILENT", m1, m2) |
| 6858 | assert result == 2 |
| 6859 | |
| 6860 | @skip_if_server_version_lt("8.7.2") |
| 6861 | def test_xnack_fail(self, r): |
nothing calls this directly
no test coverage detected