From f03b7a8011c9ae99cd22cc35a7982cf66f6edf30 Mon Sep 17 00:00:00 2001 From: Untone Date: Sun, 26 Nov 2023 22:39:08 +0300 Subject: [PATCH] listener-fix --- services/rediscache.py | 13 +++++-------- 1 file changed, 5 insertions(+), 8 deletions(-) diff --git a/services/rediscache.py b/services/rediscache.py index 92f6ae0..da69df1 100644 --- a/services/rediscache.py +++ b/services/rediscache.py @@ -53,14 +53,11 @@ class RedisCache: pubsub = self._client.pubsub() await pubsub.subscribe(channel) - try: - while True: - message = await pubsub.get_message() - if message: - yield json.loads(message['data']) - await asyncio.sleep(0.1) - finally: - await pubsub.unsubscribe(channel) + while True: + message = await pubsub.get_message() + if message and isinstance(message['data'], (str, bytes, bytearray)): + yield json.loads(message['data']) + await asyncio.sleep(0.1) redis = RedisCache()