fix: support long lines (#484)

denodrivers · Dec 27, 2024 · a151dfc · a151dfc
1 parent ad96f2c
commit a151dfc
Showing 1 changed file with 13 additions and 2 deletions.
diff --git a/protocol/deno_streams/reply.ts b/protocol/deno_streams/reply.ts
@@ -131,12 +131,23 @@ async function tryReadErrorReply(reader: BufReader): Promise<never> {
 }
 
 async function readLine(reader: BufReader): Promise<Uint8Array> {
-  const result = await reader.readLine();
+  let result = await reader.readLine();
   if (result == null) {
     throw new InvalidStateError();
   }
 
-  const { line } = result;
+  let line = result.line;
+
+  while (result?.more) {
+    result = await reader.readLine();
+    if (result == null) {
+      throw new InvalidStateError();
+    }
+    const mergedLine = new Uint8Array(line.length + result.line.length);
+    mergedLine.set(line);
+    mergedLine.set(result.line, line.length);
+    line = mergedLine;
+  }
   return line;
 }