Function addAll

packages/infra/src/MainFiberSet.ts:31–32

(fibers: readonly Fiber.Fiber<never>[])

  const set = yield* FiberSet.make<unknown, never>()
  const add = (...fibers: Fiber.Fiber<never>[]) => Effect.sync(() => fibers.forEach((_) => FiberSet.addUnsafe(set, _)))
  const addAll = (fibers: readonly Fiber.Fiber<never>[]) =>
    Effect.sync(() => fibers.forEach((_) => FiberSet.addUnsafe(set, _)))
  const join = FiberSet.size(set).pipe(
    Effect.andThen((count) => InfraLogger.logDebug(`Joining ${count} current fibers on the MainFiberSet`)),
    Effect.andThen(FiberSet.join(set))