(self, r)
| 2042 | ) |
| 2043 | |
| 2044 | def test_cluster_brpop(self, r): |
| 2045 | r.rpush("{foo}a", "1", "2") |
| 2046 | r.rpush("{foo}b", "3", "4") |
| 2047 | assert_resp_response( |
| 2048 | r, |
| 2049 | r.brpop(["{foo}b", "{foo}a"], timeout=1), |
| 2050 | (b"{foo}b", b"4"), |
| 2051 | [b"{foo}b", b"4"], |
| 2052 | ) |
| 2053 | assert_resp_response( |
| 2054 | r, |
| 2055 | r.brpop(["{foo}b", "{foo}a"], timeout=1), |
| 2056 | (b"{foo}b", b"3"), |
| 2057 | [b"{foo}b", b"3"], |
| 2058 | ) |
| 2059 | assert_resp_response( |
| 2060 | r, |
| 2061 | r.brpop(["{foo}b", "{foo}a"], timeout=1), |
| 2062 | (b"{foo}a", b"2"), |
| 2063 | [b"{foo}a", b"2"], |
| 2064 | ) |
| 2065 | assert_resp_response( |
| 2066 | r, |
| 2067 | r.brpop(["{foo}b", "{foo}a"], timeout=1), |
| 2068 | (b"{foo}a", b"1"), |
| 2069 | [b"{foo}a", b"1"], |
| 2070 | ) |
| 2071 | assert r.brpop(["{foo}b", "{foo}a"], timeout=1) is None |
| 2072 | r.rpush("{foo}c", "1") |
| 2073 | assert_resp_response( |
| 2074 | r, r.brpop("{foo}c", timeout=1), (b"{foo}c", b"1"), [b"{foo}c", b"1"] |
| 2075 | ) |
| 2076 | |
| 2077 | def test_cluster_brpoplpush(self, r): |
| 2078 | r.rpush("{foo}a", "1", "2") |
nothing calls this directly
no test coverage detected