fix: awaiting sync func

ApeWorX · Jul 12, 2024 · 8845be4 · 8845be4
1 parent 5c0a126
commit 8845be4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/silverback/subscriptions.py b/silverback/subscriptions.py
@@ -139,7 +139,7 @@ async def get_subscription_data_nowait(self, sub_id: str) -> AsyncGenerator[dict
                     await self.__anext__()
             else:
                 try:
-                    yield await queue.get_nowait()
+                    yield queue.get_nowait()
                 except asyncio.QueueEmpty:
                     pass
 
@@ -154,7 +154,7 @@ async def pop_subscription_data(self, sub_id: str) -> Union[dict, None]:
 
         if queue:
             try:
-                return await queue.get_nowait()
+                return queue.get_nowait()
             except asyncio.QueueEmpty:
                 pass