Function testOptionsValidationSync

test/parallel/test-stream-iter-to-readable.js:538–564

()

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

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

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

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

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

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

// =============================================================================
// Round-trip: stream/iter -> Readable -> stream/iter