Function testOptionsValidationAsync

test/parallel/test-stream-iter-to-readable.js:329–366

()

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

function testOptionsValidationAsync() {
  async function* gen() { yield [Buffer.from('x')]; }

  // Options must be an object
  assert.throws(() => toReadable(gen(), 'bad'),
                { code: 'ERR_INVALID_ARG_TYPE' });
  assert.throws(() => toReadable(gen(), 42),
                { code: 'ERR_INVALID_ARG_TYPE' });

  // highWaterMark must be a non-negative integer
  assert.throws(() => toReadable(gen(), { highWaterMark: -1 }),
                { code: 'ERR_OUT_OF_RANGE' });
  assert.throws(() => toReadable(gen(), { highWaterMark: 'big' }),
                { code: 'ERR_INVALID_ARG_TYPE' });
  assert.throws(() => toReadable(gen(), { highWaterMark: 1.5 }),
                { code: 'ERR_OUT_OF_RANGE' });

  // Signal must be an AbortSignal
  assert.throws(() => toReadable(gen(), { signal: 'not a signal' }),
                { code: 'ERR_INVALID_ARG_TYPE' });
  assert.throws(() => toReadable(gen(), { signal: 42 }),
                { code: 'ERR_INVALID_ARG_TYPE' });

  // Valid options should work
  const r = toReadable(gen(), { highWaterMark: 0 });
  assert.strictEqual(r.readableHighWaterMark, 0);
  r.destroy();

  // Default highWaterMark should be 16KB
  const r2 = toReadable(gen());
  assert.strictEqual(r2.readableHighWaterMark, 64 * 1024);
  r2.destroy();

  // Explicit undefined options should work (uses defaults)
  const r3 = toReadable(gen(), undefined);
  assert.strictEqual(r3.readableHighWaterMark, 64 * 1024);
  r3.destroy();
}

// =============================================================================
// fromStreamIter: with stream/iter transform