discours.io/notifier
5
0
Fork 0
Code Pull Requests Actions Activity

listener-fix
All checks were successful
deploy / deploy (push) Successful in 1m15s
Details

Browse Source
This commit is contained in:
Untone 2023-11-26 22:39:08 +03:00
parent 7ea2a911ef
commit f03b7a8011
1 changed files with 5 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
services/rediscache.py
View File

@ -53,14 +53,11 @@ class RedisCache:
pubsub = self._client.pubsub() pubsub = self._client.pubsub()
await pubsub.subscribe(channel) await pubsub.subscribe(channel)
try: while True:
while True: message = await pubsub.get_message()
message = await pubsub.get_message() if message and isinstance(message['data'], (str, bytes, bytearray)):
if message: yield json.loads(message['data'])
yield json.loads(message['data']) await asyncio.sleep(0.1)
await asyncio.sleep(0.1)
finally:
await pubsub.unsubscribe(channel)
redis = RedisCache() redis = RedisCache()