Fix pubsub client

p2p-industries · Jan 13, 2025 · 40360ef · 40360ef
1 parent 25aa71a
commit 40360ef
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/hyveos/pubsub.py b/hyveos/pubsub.py
@@ -126,7 +126,7 @@ async def _subscribe_callback(
 
         async with self.subscriptions_lock:
             if topic not in self.subscriptions:
-                stream = self.gos.subscribe(topic)
+                stream = await self.gos.subscribe(topic)
                 self.subscriptions[topic] = Subscription(
                     stream,
                     self.received_messages_publisher,