stream/iter pipeTo() does not observe abort while waiting for the next source chunk #64014

import { pipeTo } from "node:stream/iter";
import { setTimeout } from "node:timers/promises";

async function* neverYieldingSource() {
  await new Promise(() => {});
}

const writer = {
  write() {},
};

const ac = new AbortController();

setTimeout(100).then(() => {
  ac.abort(new Error("abort reason"));
});

const result = await Promise.race([
  pipeTo(neverYieldingSource(), writer, { signal: ac.signal }).then(
    () => "pipeTo resolved",
    (error) => `pipeTo rejected: ${error.name}: ${error.message}`,
  ),
  setTimeout(1000, "timed out"),
]);

console.log(result);