fix(core): handle multiple messages (#17199)

nrwl · May 24, 2023 · c57f7b8 · c57f7b8 · vercel · May 24, 2023
1 parent c9ec7d0
commit c57f7b8
Showing 1 changed file with 7 additions and 1 deletion.
diff --git 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;