From f6d04945505ef1a74efc5ef88fd26ad8e588178d Mon Sep 17 00:00:00 2001
From: Joseph Juzl <joejuzl@gmail.com>
Date: Wed, 12 Jun 2019 09:36:19 +0200
Subject: [PATCH] Add redis stream methods to the client stubs

---
 third_party/2and3/redis/client.pyi | 31 ++++++++++++++++++++++++++++++
 1 file changed, 31 insertions(+)

diff --git a/third_party/2and3/redis/client.pyi b/third_party/2and3/redis/client.pyi
index f41676177336..274c6d8aecce 100644
--- a/third_party/2and3/redis/client.pyi
+++ b/third_party/2and3/redis/client.pyi
@@ -169,6 +169,37 @@ class StrictRedis:
     def srem(self, name, *values): ...
     def sunion(self, keys, *args): ...
     def sunionstore(self, dest, keys, *args): ...
+    def xack(self, name, groupname, *ids): ...
+    def xadd(self, name, fields, id=..., maxlen=..., approximate=...): ...
+    def xclaim(
+        self,
+        name,
+        groupname,
+        consumername,
+        min_idle_time,
+        message_ids,
+        idle=...,
+        time=...,
+        retrycount=...,
+        force=...,
+        justid=...,
+    ): ...
+    def xdel(self, name, *ids): ...
+    def xgroup_create(self, name, groupname, id=..., mkstream=...): ...
+    def xgroup_delconsumer(self, name, groupname, consumername): ...
+    def xgroup_destroy(self, name, groupname): ...
+    def xgroup_setid(self, name, groupname, id): ...
+    def xinfo_consumers(self, name, groupname): ...
+    def xinfo_groups(self, name): ...
+    def xinfo_stream(self, name): ...
+    def xlen(self, name): ...
+    def xpending(self, name, groupname): ...
+    def xpending_range(self, name, groupname, min, max, count, consumername=...): ...
+    def xrange(self, name, min=..., max=..., count=...): ...
+    def xread(self, streams, count=..., block=...): ...
+    def xreadgroup(self, groupname, consumername, streams, count=..., block=..., noack=...): ...
+    def xrevrange(self, name, max=..., min=..., count=...): ...
+    def xtrim(self, name, maxlen, approximate=...): ...
     def zadd(self, name, *args, **kwargs): ...
     def zcard(self, name): ...
     def zcount(self, name, min, max): ...