Method test_xnack_force

tests/test_commands.py:6923–6930

(self, r)

    @skip_if_server_version_lt("8.7.2")
    def test_xnack_force(self, r):
        stream = "stream"
        group = "group"
        m1 = r.xadd(stream, {"foo": "bar"})
        r.xgroup_create(stream, group, 0)
        # FORCE creates unowned PEL entries for IDs not already in PEL
        result = r.xnack(stream, group, "FAIL", m1, force=True)
        assert result == 1

    @skip_if_server_version_lt("8.7.2")
    def test_xnack_invalid_mode(self, r):