Function shareSync

lib/internal/streams/iter/share.js:682–700

(source, options = { __proto__: null })

}

function shareSync(source, options = { __proto__: null }) {
  // Normalize source via fromSync() - accepts strings, ArrayBuffers, protocols, etc.
  const normalized = fromSync(source);
  validateObject(options, 'options');
  const {
    highWaterMark = kMultiConsumerDefaultHWM,
    backpressure = 'strict',
  } = options;
  validateInteger(highWaterMark, 'options.highWaterMark');
  validateBackpressure(backpressure);

  const opts = {
    __proto__: null,
    highWaterMark: clampHWM(highWaterMark),
    backpressure,
  };

  return new SyncShareImpl(normalized, opts);
}

function isShareable(value) {
  return hasProtocol(value, shareProtocol);