Function testPipeToWithSignal

test/parallel/test-stream-iter-pipeto.js:88–104

()

// PipeTo with AbortSignal
async function testPipeToWithSignal() {
  const ac = new AbortController();
  const chunks = [];
  const writer = {
    write(chunk) { chunks.push(chunk); },
  };
  async function* slowSource() {
    yield [new TextEncoder().encode('a')];
    await new Promise((r) => setTimeout(r, 50));
    yield [new TextEncoder().encode('b')];
  }
  ac.abort();
  await assert.rejects(
    () => pipeTo(slowSource(), writer, { signal: ac.signal }),
    { name: 'AbortError' },
  );
}

// PipeTo with transforms
async function testPipeToWithTransforms() {