diff --git a/ypy_websocket/websocket_provider.py b/ypy_websocket/websocket_provider.py
index 32c1e42..20d7536 100644
--- 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