Function cleanupIterators

lib/internal/streams/iter/consumers.js:516–542

(iterators, primaryError)

}

async function cleanupIterators(iterators, primaryError) {
  let cleanupError;
  await SafePromiseAllReturnVoid(iterators, async (iterator) => {
    if (iterator.return) {
      try {
        await iterator.return();
      } catch (err) {
        // Keep the first cleanup error encountered.
        cleanupError ??= err;
      }
    }
  });
  if (cleanupError !== undefined) {
    if (primaryError !== undefined) {
      // Both a primary error and a cleanup error occurred.
      // Wrap in SuppressedError so neither is lost:
      // .error = primaryError, .suppressed = cleanupError.
      // eslint-disable-next-line no-restricted-syntax
      throw new SuppressedError(primaryError, cleanupError);
    }
    // No primary error - the cleanup error is the only error.
    throw cleanupError;
  }
  if (primaryError !== undefined) {
    throw primaryError;
  }
}

module.exports = {
  array,