Fix WebsocketProvider

y-crdt · Nov 17, 2022 · bfbb1d0 · bfbb1d0
1 parent aa52eb2
commit bfbb1d0
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/ypy_websocket/websocket_provider.py b/ypy_websocket/websocket_provider.py
@@ -4,7 +4,7 @@
 
 import y_py as Y
 
-from .yutils import YMessageType, process_sync_message, put_updates, sync
+from .yutils import YMessageType, create_update_message, process_sync_message, put_updates, sync
 
 
 class WebsocketProvider:
@@ -31,7 +31,8 @@ async def _run(self):
     async def _send(self):
         while True:
             update = await self._update_queue.get()
+            message = create_update_message(update)
             try:
-                await self._websocket.send(update)
+                await self._websocket.send(message)
             except Exception:
                 pass