Function pullSync

lib/internal/streams/iter/pull.js:874–888

* Create a sync pull-through pipeline with transforms. * @param {Iterable} source - The sync streamable source * @param {...Function} transforms - Variadic transforms * @returns {Iterable }

(source, ...transforms)

 * @returns {Iterable<Uint8Array[]>}
 */
function pullSync(source, ...transforms) {
  for (let i = 0; i < transforms.length; i++) {
    if (!isTransform(transforms[i])) {
      throw new ERR_INVALID_ARG_TYPE(
        `transforms[${i}]`, ['Function', 'Object with transform()'],
        transforms[i]);
    }
  }
  return {
    __proto__: null,
    *[SymbolIterator]() {
      yield* createSyncPipeline(fromSync(source), transforms);
    },
  };
}

/**
 * Create an async pull-through pipeline with transforms.