diff --git a/thingsdb/client/protocol.py b/thingsdb/client/protocol.py index 44ccc30..ee1f050 100644 --- a/thingsdb/client/protocol.py +++ b/thingsdb/client/protocol.py @@ -36,6 +36,9 @@ pass +WEBSOCKET_MAX_SIZE = 2**24 # default from websocket is 2**20 + + class Proto(enum.IntEnum): # Events ON_NODE_STATUS = 0x00 @@ -354,7 +357,7 @@ def __init__( self._is_closing = False async def connect(self, uri, ssl: SSLContext): - self._proto = await connect(uri, ssl=ssl, max_size=2**24) + self._proto = await connect(uri, ssl=ssl, max_size=WEBSOCKET_MAX_SIZE) asyncio.create_task(self._recv_loop()) self._is_closing = False return self