Function collectAsync

lib/internal/streams/iter/consumers.js:120–155

* Collect chunks from an async or sync source into an array. * @param {AsyncIterable |Iterable } source * @param {AbortSignal} [signal] * @param {number} [limit] * @returns {Promise }

(source, signal, limit)

 * @returns {Promise<Uint8Array[]>}
 */
async function collectAsync(source, signal, limit) {
  signal?.throwIfAborted();

  // Normalize source via from() - accepts strings, ArrayBuffers, protocols, etc.
  const normalized = from(source);
  const chunks = [];

  // Fast path: no signal and no limit
  if (!signal && limit === undefined) {
    for await (const batch of normalized) {
      for (let i = 0; i < batch.length; i++) {
        ArrayPrototypePush(chunks, batch[i]);
      }
    }
    return chunks;
  }

  // Slow path: with signal or limit checks
  let totalBytes = 0;

  for await (const batch of normalized) {
    signal?.throwIfAborted();
    for (let i = 0; i < batch.length; i++) {
      const chunk = batch[i];
      if (limit !== undefined) {
        totalBytes += TypedArrayPrototypeGetByteLength(chunk);
        if (totalBytes > limit) {
          throw new ERR_OUT_OF_RANGE('totalBytes', `<= ${limit}`, totalBytes);
        }
      }
      ArrayPrototypePush(chunks, chunk);
    }
  }

  return chunks;
}

/**
 * Convert a Uint8Array to its backing ArrayBuffer, slicing if necessary.