Function testSignalAsync

test/parallel/test-stream-iter-to-readable.js:282–303

()

// =============================================================================

async function testSignalAsync() {
  async function* gen() {
    for (let i = 0; ; i++) {
      yield [Buffer.from(`chunk${i}`)];
    }
  }

  const ac = new AbortController();
  const readable = toReadable(gen(), { signal: ac.signal });

  const chunks = [];
  await assert.rejects(async () => {
    for await (const chunk of readable) {
      chunks.push(chunk);
      if (chunks.length >= 3) {
        ac.abort();
      }
    }
  }, { name: 'AbortError' });
  assert.ok(chunks.length >= 3);
  assert.ok(readable.destroyed);
}

// =============================================================================
// fromStreamIter: signal already aborted