Function testSignalAlreadyAborted

test/parallel/test-stream-iter-to-readable.js:309–323

()

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

async function testSignalAlreadyAborted() {
  async function* gen() {
    yield [Buffer.from('should not reach')];
  }

  const readable = toReadable(gen(), { signal: AbortSignal.abort() });

  await assert.rejects(async () => {
    // eslint-disable-next-line no-unused-vars
    for await (const chunk of readable) {
      // Should not receive any data
    }
  }, { name: 'AbortError' });
  assert.ok(readable.destroyed);
}

// =============================================================================
// fromStreamIter: options validation