Fix logic around reading more push messages

redis · Jun 12, 2024 · 6f9f786 · 6f9f786
1 parent a9dabf9
commit 6f9f786
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/redis/_parsers/resp3.py b/redis/_parsers/resp3.py
@@ -132,7 +132,7 @@ def handle_push_response(self, response, disable_decoding, push_request):
             res = self.invalidation_push_handler_func(response)
         else:
             res = self.pubsub_push_handler_func(response)
-        if not push_request:
+        if push_request:
             return self._read_response(
                 disable_decoding=disable_decoding, push_request=push_request
             )
@@ -276,7 +276,7 @@ async def handle_push_response(self, response, disable_decoding, push_request):
             res = self.invalidation_push_handler_func(response)
         else:
             res = self.pubsub_push_handler_func(response)
-        if not push_request:
+        if push_request:
             return await self._read_response(
                 disable_decoding=disable_decoding, push_request=push_request
             )