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;