Function pipeToSync

lib/internal/streams/iter/pull.js:932–983

* Write a sync source through transforms to a sync writer. * @param {Iterable } source * @param {...(Function|object)} args - Transforms, writer, and optional options * @returns {number} Total bytes written

(source, ...args)

 * @returns {number} Total bytes written
 */
function pipeToSync(source, ...args) {
  const { transforms, writer, options } = parsePipeToArgs(args, 'writeSync');

  // Normalize source and create pipeline
  const normalized = fromSync(source);
  const pipeline = transforms.length > 0 ?
    createSyncPipeline(normalized, transforms) :
    normalized;

  let totalBytes = 0;
  const hasWritevSync = typeof writer.writevSync === 'function';
  const hasEndSync = typeof writer.endSync === 'function';

  try {
    let canContinue = true;
    for (const batch of pipeline) {
      if (!canContinue) {
        break;
      }
      if (hasWritevSync && batch.length > 1) {
        if (writer.writevSync(batch) === false) {
          break;
        }
        for (let i = 0; i < batch.length; i++) {
          totalBytes += TypedArrayPrototypeGetByteLength(batch[i]);
        }
      } else {
        for (let i = 0; i < batch.length; i++) {
          const chunk = batch[i];
          if (writer.writeSync(chunk) === false) {
            canContinue = false;
            break;
          }
          totalBytes += TypedArrayPrototypeGetByteLength(chunk);
        }
      }
    }

    if (!options?.preventClose) {
      if (!hasEndSync || writer.endSync() < 0) {
        writer.end?.();
      }
    }
  } catch (error) {
    if (!options?.preventFail) {
      writer.fail?.(wrapError(error));
    }
    throw error;
  }

  return totalBytes;
}

/**
 * Write an async source through transforms to a writer.