Function collectStderr

src/ssh/createSSHSession.ts:429–450

(proc: Subprocess, chunks: string[])

}

function collectStderr(proc: Subprocess, chunks: string[]): void {
  const stderr = proc.stderr
  if (!stderr) return

  const reader = (stderr as ReadableStream<Uint8Array>).getReader()
  const decoder = new TextDecoder()

  void (async () => {
    try {
      while (true) {
        const { done, value } = await reader.read()
        if (done) break
        chunks.push(decoder.decode(value, { stream: true }))
        if (chunks.length > STDERR_TAIL_LINES * 2) {
          chunks.splice(0, chunks.length - STDERR_TAIL_LINES)
        }
      }
    } catch {
      // stderr closed — expected on process exit
    }
  })()
}