Function processStream

src/node/services/coderService.ts:200–226

(stream: NodeJS.ReadableStream | null, isStderr: boolean)

    };

    const processStream = (stream: NodeJS.ReadableStream | null, isStderr: boolean) => {
      if (!stream) {
        markDone();
        return;
      }
      let buffer = "";
      stream.on("data", (chunk: Buffer) => {
        buffer += chunk.toString();
        const parts = buffer.split("\n");
        buffer = parts.pop() ?? "";
        for (const line of parts) {
          const trimmed = line.trim();
          if (trimmed) {
            pushLine(trimmed);
            if (isStderr) stderrLines.push(trimmed);
          }
        }
      });
      stream.on("end", () => {
        if (buffer.trim()) {
          pushLine(buffer.trim());
          if (isStderr) stderrLines.push(buffer.trim());
        }
        markDone();
      });
      stream.on("error", markDone);
    };

    processStream(child.stdout, false);
    processStream(child.stderr, true);