fix: allow pubnub unsub to complete since nothing currently waits (#114)

bdraco · Jun 9, 2024 · 82b0c58 · 82b0c58
1 parent 51408fb
commit 82b0c58
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/yalexs/pubnub_async.py b/yalexs/pubnub_async.py
@@ -1,5 +1,6 @@
 """Connect to pubnub."""
 
+import asyncio
 import datetime
 import logging
 from collections.abc import Coroutine
@@ -126,6 +127,9 @@ def async_create_pubnub(
     async def _async_unsub():
         _LOGGER.debug("Removing listeners PubNub")
         pubnub.remove_listener(subscriptions)
+        _LOGGER.debug("Unsubscribing from PubNub")
+        pubnub.unsubscribe_all()
+        await asyncio.sleep(0.1)  # Allow the unsubscribe to complete
         _LOGGER.debug("Stopping PubNub")
         await pubnub.stop()
         _LOGGER.debug("PubNub stopped")