Function testAbortSignal

test/parallel/test-stream-iter-readable-interop.js:568–589

()

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

async function testAbortSignal() {
  let pushCount = 0;
  const readable = new Readable({
    read() {
      this.push(Buffer.from(`sig${pushCount++}`));
      // Never pushes null - infinite stream
    },
  });

  const ac = new AbortController();
  const chunks = [];

  await assert.rejects(async () => {
    for await (const batch of pull(readable, { signal: ac.signal })) {
      chunks.push(...batch);
      if (chunks.length >= 2) {
        ac.abort();
      }
    }
  }, { name: 'AbortError' });
  assert.ok(chunks.length >= 2);
}

// =============================================================================
// kValidatedSource identity - from() returns same object for validated sources