Function fiberAll

packages/effect/src/internal/fiberRuntime.ts:3438–3482

(fibers: Iterable<Fiber.Fiber<A, E>>)

/** @internal */
export const fiberAll = <A, E>(fibers: Iterable<Fiber.Fiber<A, E>>): Fiber.Fiber<Array<A>, E> => {
  const _fiberAll = {
    ...Effectable.CommitPrototype,
    commit() {
      return internalFiber.join(this)
    },
    [internalFiber.FiberTypeId]: internalFiber.fiberVariance,
    id: () =>
      RA.fromIterable(fibers).reduce((id, fiber) => FiberId.combine(id, fiber.id()), FiberId.none as FiberId.FiberId),
    await: core.exit(forEachParUnbounded(fibers, (fiber) => core.flatten(fiber.await), false)),
    children: core.map(forEachParUnbounded(fibers, (fiber) => fiber.children, false), RA.flatten),
    inheritAll: core.forEachSequentialDiscard(fibers, (fiber) => fiber.inheritAll),
    poll: core.map(
      core.forEachSequential(fibers, (fiber) => fiber.poll),
      RA.reduceRight(
        Option.some<Exit.Exit<Array<A>, E>>(core.exitSucceed(new Array())),
        (optionB, optionA) => {
          switch (optionA._tag) {
            case "None": {
              return Option.none()
            }
            case "Some": {
              switch (optionB._tag) {
                case "None": {
                  return Option.none()
                }
                case "Some": {
                  return Option.some(
                    core.exitZipWith(optionA.value, optionB.value, {
                      onSuccess: (a, chunk) => [a, ...chunk],
                      onFailure: internalCause.parallel
                    })
                  )
                }
              }
            }
          }
        }
      )
    ),
    interruptAsFork: (fiberId: FiberId.FiberId) =>
      core.forEachSequentialDiscard(fibers, (fiber) => fiber.interruptAsFork(fiberId))
  }
  return _fiberAll
}

/* @internal */
export const fiberInterruptFork = <A, E>(self: Fiber.Fiber<A, E>): Effect.Effect<void> =>