Function all

packages/effect/src/unstable/reactivity/AsyncResult.ts:673–709

(
  results: Arg
)

 * @since 4.0.0
 */
export const all = <const Arg extends Iterable<any> | Record<string, any>>(
  results: Arg
): AsyncResult<
  [Arg] extends [ReadonlyArray<any>] ? {
      -readonly [K in keyof Arg]: [Arg[K]] extends [AsyncResult<infer _A, infer _E>] ? _A : Arg[K]
    }
    : [Arg] extends [Iterable<infer _A>] ? _A extends AsyncResult<infer _AA, infer _E> ? _AA : _A
    : [Arg] extends [Record<string, any>] ? {
        -readonly [K in keyof Arg]: [Arg[K]] extends [AsyncResult<infer _A, infer _E>] ? _A : Arg[K]
      }
    : never,
  [Arg] extends [ReadonlyArray<any>] ? AsyncResult.Failure<Arg[number]>
    : [Arg] extends [Iterable<infer _A>] ? AsyncResult.Failure<_A>
    : [Arg] extends [Record<string, any>] ? AsyncResult.Failure<Arg[keyof Arg]>
    : never
> => {
  const isIter = isIterable(results)
  const entries = isIter
    ? Array.from(results, (result, i) => [i, result] as const)
    : Object.entries(results)
  const successes: any = isIter ? [] : {}
  let waiting = false
  for (let i = 0; i < entries.length; i++) {
    const [key, result] = entries[i]
    if (!isAsyncResult(result)) {
      InternalRecord.assignProperty(successes, key, result)
      continue
    } else if (!isSuccess(result)) {
      return result as any
    }
    InternalRecord.assignProperty(successes, key, result.value)
    if (result.waiting) {
      waiting = true
    }
  }
  return success(successes, { waiting }) as any
}

/**
 * Creates a typed builder for rendering an `AsyncResult` by handling waiting, initial, success, error, defect, interrupt, and failure cases.