2 files changed, 6 insertions, 4 deletions
diff --git a/client/src/network/MessagePublisher.ts b/client/src/network/MessagePublisher.ts
index de105c5..c0aec28 100644
--- a/client/src/network/MessagePublisher.ts
+++ b/client/src/network/MessagePublisher.ts
@@ -1,5 +1,5 @@
 import type { Message, MessagePublisher } from '@engine/network';
-import { stringify } from '@engine/utils';
+import { serialize } from '@engine/utils';
 
 export class ClientSocketMessagePublisher implements MessagePublisher {
   private socket: WebSocket;
@@ -17,7 +17,7 @@ export class ClientSocketMessagePublisher implements MessagePublisher {
   public publish() {
     if (this.socket.readyState == WebSocket.OPEN) {
       this.messages.forEach((message: Message) =>
-        this.socket.send(stringify(message))
+        this.socket.send(serialize(message))
       );
       this.messages = [];
     }
diff --git a/client/src/network/MessageQueueReceiver.ts b/client/src/network/MessageQueueReceiver.ts
index 46ca5cc..cb74cf7 100644
--- a/client/src/network/MessageQueueReceiver.ts
+++ b/client/src/network/MessageQueueReceiver.ts
@@ -10,8 +10,10 @@ export class ClientSocketMessageQueueProvider implements MessageQueueProvider {
     this.messages = [];
 
     this.socket.addEventListener('message', (e) => {
-      const messages = parse<Message[]>(e.data);
-      this.messages = this.messages.concat(messages);
+      e.data.arrayBuffer().then((buffer) => {
+        const messages = parse<Message[]>(new Uint8Array(buffer));
+        this.messages = this.messages.concat(messages);
+      });
     });
   }