Body timeout not working about undici HOT 5 CLOSED

const fs = require('node:fs');
const { pipeline } = require('node:stream/promises');
const http = require('node:http');
const { request } = require('undici');

const server = http.createServer((req, res) => {
    res.writeHead(200);
    setTimeout(() => {
        res.end();
        console.log('Request closed after 10 seconds');
    }, 10000);
    const writeZeroes = () => {
        res.write(Buffer.alloc(1024, 0));
        setImmediate(writeZeroes);
    };
    writeZeroes();
});

server.listen();
const serverUrl = `http://localhost:${server.address().port}`;
console.log(`Server listening on ${serverUrl}`);

async function test() {
    const { body } = await request(serverUrl, {
        throwOnError: true,
        bodyTimeout: 1000,
    });
    console.log('Reading body...');
    await pipeline(body, fs.createWriteStream('/tmp/body-timeout-test'));
    console.log('Reading body finished');
}

test();

const fs = require('node:fs')
const { pipeline } = require('node:stream/promises')
const http = require('node:http')
const { request } = require('undici')

const server = http.createServer((req, res) => {
  res.writeHead(200)
  setTimeout(() => {
    res.end()
    console.log('Request closed after 10 seconds')
  }, 10000).unref()
  const writeZeroes = () => {
    res.write(Buffer.alloc(1024, 0))
    setInterval(writeZeroes, 2000)
  }
  writeZeroes()
})

server.listen(0, () => {
  const serverUrl = `http://localhost:${server.address().port}`
  console.log(`Server listening on ${serverUrl}`)

  async function test () {
    console.log('Sending request...')
    const { body } = await request(serverUrl, {
      throwOnError: true,
      bodyTimeout: 1000
    })
    console.log('Reading body...')
    await pipeline(body, fs.createWriteStream('/tmp/body-timeout-test'))
    console.log('Reading body finished')
  }

  test()
})