Function slowSource

test/parallel/test-stream-iter-pipeto.js:94–98

()

    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 }),