Function validateBaseConsumerOptions

lib/internal/streams/iter/consumers.js:187–204

(options)

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

function validateBaseConsumerOptions(options) {
  validateObject(options, 'options');
  if (options.limit !== undefined) {
    validateInteger(options.limit, 'options.limit', 0);
  }
  if (options.encoding !== undefined) {
    if (typeof options.encoding !== 'string') {
      throw new ERR_INVALID_ARG_TYPE('options.encoding', 'string',
                                     options.encoding);
    }
    try {
      new TextDecoder(options.encoding);
    } catch {
      throw new ERR_INVALID_ARG_VALUE.RangeError(
        'options.encoding', options.encoding);
    }
  }
}

function validateConsumerOptions(options) {
  validateBaseConsumerOptions(options);