Upd max_size

Author: joente

thingsdb/client/client.py

@@ -451,7 +451,7 @@ def run(
 
     def _emit(
             self,
-            room_id: int,
+            room_id: Union[int, str],
             event: str,
             *args: Optional[Any],
             scope: Optional[str] = None,
@@ -462,7 +462,7 @@ def _emit(
         emit an event to a roomId.
 
         Args:
-            room_id (int):
+            room_id (int/str):
                 Room Id to emit the event to.
             event (str):
                 Name of the event to emit.

thingsdb/client/protocol.py

@@ -354,7 +354,7 @@ def __init__(
         self._is_closing = False
 
     async def connect(self, uri, ssl: SSLContext):
-        self._proto = await connect(uri, ssl=ssl)
+        self._proto = await connect(uri, ssl=ssl, max_size=2**24)
         asyncio.create_task(self._recv_loop())
         self._is_closing = False
         return self

thingsdb/version.py

@@ -1 +1 @@
-__version__ = '1.1.3'
+__version__ = '1.1.4'