Function raceAllFirst

packages/effect/src/Micro.ts:1457–1481

(
  all: Iterable<Eff>
)

 * @category sequencing
 */
export const raceAllFirst = <Eff extends Micro<any, any, any>>(
  all: Iterable<Eff>
): Micro<Micro.Success<Eff>, Micro.Error<Eff>, Micro.Context<Eff>> =>
  withMicroFiber((parent) =>
    async((resume) => {
      let done = false
      const fibers = new Set<MicroFiber<any, any>>()
      const onExit = (exit: MicroExit<any, any>) => {
        done = true
        resume(fibers.size === 0 ? exit : flatMap(fiberInterruptAll(fibers), () => exit))
      }

      for (const effect of all) {
        if (done) break
        const fiber = unsafeFork(parent, interruptible(effect), true, true)
        fibers.add(fiber)
        fiber.addObserver((exit) => {
          fibers.delete(fiber)
          onExit(exit)
        })
      }

      return fiberInterruptAll(fibers)
    })
  )

/**
 * Returns an effect that races two effects, yielding the value of the first