add compression to engine messagesHEADmain

1 files changed, 4 insertions, 2 deletions

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);
+      });
     });
   }