From c57f7b825d565696e4049fa61dc4c475547d36a0 Mon Sep 17 00:00:00 2001
From: William Sedlacek <william.sedlacek@icloud.com>
Date: Wed, 24 May 2023 15:26:09 -0700
Subject: [PATCH] fix(core): handle multiple messages (#17199)

---
 packages/nx/src/utils/consume-messages-from-socket.ts | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/packages/nx/src/utils/consume-messages-from-socket.ts b/packages/nx/src/utils/consume-messages-from-socket.ts
index 2362d56cfd..1abb4ee014 100644
--- a/packages/nx/src/utils/consume-messages-from-socket.ts
+++ b/packages/nx/src/utils/consume-messages-from-socket.ts
@@ -4,7 +4,13 @@ export function consumeMessagesFromSocket(callback: (message: string) => void) {
     const chunk = data.toString();
     if (chunk.codePointAt(chunk.length - 1) === 4) {
       message += chunk.substring(0, chunk.length - 1);
-      callback(message);
+
+      // Server may send multiple messages in one chunk, so splitting by 0x4
+      const messages = message.split('');
+      for (const splitMessage of messages) {
+        callback(splitMessage);
+      }
+
       message = '';
     } else {
       message += chunk;