diff --git a/python/src/wslink/protocol.py b/python/src/wslink/protocol.py index 027a1f3..9cc929c 100644 --- a/python/src/wslink/protocol.py +++ b/python/src/wslink/protocol.py @@ -7,7 +7,7 @@ import traceback from wslink import schedule_coroutine -from wslink import publish as pub +from wslink.publish import PublishManager class AbstractWebApp: @@ -136,6 +136,7 @@ def __init__(self, protocol=None, web_app=None): self.connections = {} self.authentified_client_ids = set() self.attachment_atomic = asyncio.Lock() + self.pub_manager = PublishManager() # Build the rpc method dictionary, assuming we were given a serverprotocol if self.getServerProtocol(): @@ -165,7 +166,7 @@ def getServerProtocol(self): @property def publishManager(self): - return pub.publishManager + return self.pub_manager @property def reverse_connection_client_id(self):