Fixed bug with missing async operator

Author: vladvildanov

redis/_parsers/resp3.py

@@ -17,7 +17,7 @@ def __init__(self, socket_read_size):
         self.pubsub_push_handler_func = self.handle_pubsub_push_response
         self.invalidation_push_handler_func = None
 
-    def handle_pubsub_push_response(self, response):
+    async def handle_pubsub_push_response(self, response):
         logger = getLogger("push_response")
         logger.info("Push response: " + str(response))
         return response

tests/test_asyncio/test_pubsub.py

@@ -461,7 +461,7 @@ async def test_get_message_without_subscribe(self, r: redis.Redis, pubsub):
 
 @pytest.mark.onlynoncluster
 class TestPubSubRESP3Handler:
-    def my_handler(self, message):
+    async def my_handler(self, message):
         self.message = ["my handler", message]
 
     @pytest.mark.skipif(HIREDIS_AVAILABLE, reason="PythonParser only")