接続はできているのに、本文が途中で止まる。ヘッダまで・全体・無通信の3つのタイムアウトを同じ応答で測りました

// timeout-lab.mjs — 本文が途中で止まる応答に、3 種類のタイムアウトを当てて挙動を比べる
import http from "node:http";
 
// --- 検証用サーバー：3 つの挙動を再現する -------------------------------
const chunk = "x".repeat(5 * 1024); // 5KB
const server = http.createServer((req, res) => {
  res.writeHead(200, { "content-type": "text/plain" });
  if (req.url === "/fast") {            // 健全：50ms ごとに 20 回 ≒ 1.0 秒で完了
    let n = 0;
    const t = setInterval(() => { res.write(chunk); if (++n === 20) { clearInterval(t); res.end(); } }, 50);
  } else if (req.url === "/slow") {     // 健全だが遅い：400ms ごとに 12 回 ≒ 4.8 秒で完了
    let n = 0;
    const t = setInterval(() => { res.write(chunk); if (++n === 12) { clearInterval(t); res.end(); } }, 400);
  } else if (req.url === "/stall") {    // 異常：ヘッダと 3 回分だけ送り、あとは何も送らず閉じもしない
    let n = 0;
    const t = setInterval(() => { res.write(chunk); if (++n === 3) clearInterval(t); }, 50);
  }
});
await new Promise((r) => server.listen(0, r));
const BASE = `http://127.0.0.1:${server.address().port}`;
 
// --- 3 つの読み取り方 ---------------------------------------------------
// A: ヘッダが届くまでだけ時間を計る（本文は無期限）
async function readA(url, ms) {
  const ac = new AbortController();
  const timer = setTimeout(() => ac.abort(), ms);
  const res = await fetch(url, { signal: ac.signal });
  clearTimeout(timer); // ← ヘッダが届いた時点で止めてしまう
  return await res.text();
}
// B: 全体に上限を付ける（ヘッダも本文も込みで ms）
async function readB(url, ms) {
  const res = await fetch(url, { signal: AbortSignal.timeout(ms) });
  return await res.text();
}
// C: 無通信が ms 続いたら中断（チャンクが届くたびに時計を戻す）
async function readC(url, idleMs) {
  const ac = new AbortController();
  let timer = setTimeout(() => ac.abort(), idleMs);
  const res = await fetch(url, { signal: ac.signal });
  let bytes = 0;
  for await (const part of res.body) {
    bytes += part.length;
    clearTimeout(timer);
    timer = setTimeout(() => ac.abort(), idleMs);
  }
  clearTimeout(timer);
  return "x".repeat(bytes);
}
 
// --- 計測 ---------------------------------------------------------------
async function run(label, fn, url, ms, cap) {
  const t0 = performance.now();
  const outcome = await Promise.race([
    fn(`${BASE}${url}`, ms).then((b) => `完了 ${(b.length / 1024).toFixed(0)}KB`, (e) => `中断 (${e.name})`),
    new Promise((r) => setTimeout(() => r(`待機打ち切り（${cap}ms 経過しても終わらず）`), cap)),
  ]);
  const el = Math.round(performance.now() - t0);
  console.log(`${label.padEnd(34)} ${String(el).padStart(5)}ms  ${outcome}`);
}
 
const CAP = 8000;
console.log("--- 異常（本文が途中で止まる）---");
await run("A ヘッダまで 3000ms / stall", readA, "/stall", 3000, CAP);
await run("B 全体 3000ms / stall", readB, "/stall", 3000, CAP);
await run("C 無通信 1500ms / stall", readC, "/stall", 1500, CAP);
console.log("--- 健全だが遅い（4.8 秒で完了）---");
await run("A ヘッダまで 3000ms / slow", readA, "/slow", 3000, CAP);
await run("B 全体 3000ms / slow", readB, "/slow", 3000, CAP);
await run("C 無通信 1500ms / slow", readC, "/slow", 1500, CAP);
console.log("--- 健全で速い（1.0 秒で完了）---");
await run("B 全体 3000ms / fast", readB, "/fast", 3000, CAP);
await run("C 無通信 1500ms / fast", readC, "/fast", 1500, CAP);
server.closeAllConnections(); server.close();