/**
 * Reduces an `Collection<Effect<R, E, A>>` to a single `Effect<R, E, A>`, working
 * in parallel.
 *
 * @tsplus static effect/core/io/Effect.Ops reduceAllPar
 */
export function reduceAllPar<R, E, A>(
  a: Effect<R, E, A>,
  as: Collection<Effect<R, E, A>>,
  f: (acc: A, a: A) => A
): Effect<R, E, A> {
  return Effect.suspendSucceed(
    Effect.mergeAllPar<R, E, A, Maybe<A>>(
      Collection.of(a).concat(as),
      Maybe.none,
      (acc, elem) =>
        Maybe.some(
          acc.fold(
            () => elem,
            (a) => f(a, elem)
          )
        )
    ).map((option) =>
      option.getOrElse(() => {
        throw new Error("Bug")
      })
    )
  )
}