Function raceAll

packages/effect/src/Micro.ts:1410–1446

(
  all: Iterable<Eff>
)

 * @category sequencing
 */
export const raceAll = <Eff extends Micro<any, any, any>>(
  all: Iterable<Eff>
): Micro<Micro.Success<Eff>, Micro.Error<Eff>, Micro.Context<Eff>> =>
  withMicroFiber((parent) =>
    async((resume) => {
      const effects = Arr.fromIterable(all)
      const len = effects.length
      let doneCount = 0
      let done = false
      const fibers = new Set<MicroFiber<any, any>>()
      const causes: Array<MicroCause<any>> = []
      const onExit = (exit: MicroExit<any, any>) => {
        doneCount++
        if (exit._tag === "Failure") {
          causes.push(exit.cause)
          if (doneCount >= len) {
            resume(failCause(causes[0]))
          }
          return
        }
        done = true
        resume(fibers.size === 0 ? exit : flatMap(uninterruptible(fiberInterruptAll(fibers)), () => exit))
      }

      for (let i = 0; i < len; i++) {
        if (done) break
        const fiber = unsafeFork(parent, interruptible(effects[i]), true, true)
        fibers.add(fiber)
        fiber.addObserver((exit) => {
          fibers.delete(fiber)
          onExit(exit)
        })
      }

      return fiberInterruptAll(fibers)
    })
  )

/**
 * Returns an effect that races all the specified effects,