Function writeBatch

lib/internal/streams/iter/pull.js:1033–1063

(batch)

  // Returns undefined on sync success, or a Promise when async fallback
  // is required. Callers must check: const p = writeBatch(b); if (p) await p;
  function writeBatch(batch) {
    if (hasWritev && batch.length > 1) {
      if (!hasWritevSync || !writer.writevSync(batch)) {
        const opts = signal ? { __proto__: null, signal } : undefined;
        const writevResult = writer.writev(batch, opts);
        if (writevResult === undefined) {
          for (let i = 0; i < batch.length; i++) {
            totalBytes += TypedArrayPrototypeGetByteLength(batch[i]);
          }
          return;
        }
        return PromisePrototypeThen(PromiseResolve(writevResult), () => {
          for (let i = 0; i < batch.length; i++) {
            totalBytes += TypedArrayPrototypeGetByteLength(batch[i]);
          }
        });
      }
      for (let i = 0; i < batch.length; i++) {
        totalBytes += TypedArrayPrototypeGetByteLength(batch[i]);
      }
      return;
    }
    for (let i = 0; i < batch.length; i++) {
      const chunk = batch[i];
      if (!hasWriteSync || !writer.writeSync(chunk)) {
        // Sync path failed at index i - fall back to async for the rest.
        return writeBatchAsyncFallback(batch, i);
      }
      totalBytes += TypedArrayPrototypeGetByteLength(chunk);
    }
  }

  try {
    if (useSyncIterableFastPath) {