Function testAbortMidCompression

test/parallel/test-stream-iter-transform-coverage.js:32–44

()

// Abort mid-compression triggers finally cleanup
async function testAbortMidCompression() {
  const ac = new AbortController();
  const largeInput = 'x'.repeat(100_000);
  const compressed = pull(from(largeInput), compressGzip(),
                          { signal: ac.signal });
  const iter = compressed[Symbol.asyncIterator]();

  // Read one batch then abort
  const first = await iter.next();
  assert.strictEqual(first.done, false);
  ac.abort();
  await assert.rejects(iter.next(), { name: 'AbortError' });
}

// Early consumer exit (break from for-await) triggers finally
async function testEarlyConsumerExit() {