Function task

packages/effect/test/Effect/traversing.test.ts:344–360

(
        started: Ref.Ref<number>,
        trigger: Deferred.Deferred<void, never>,
        n: number
      )

  it.effect("forEach/concurrency+discard - accumulates errors", () =>
    Effect.gen(function*() {
      const task = (
        started: Ref.Ref<number>,
        trigger: Deferred.Deferred<void, never>,
        n: number
      ): Effect.Effect<void, number> => {
        return pipe(
          Ref.updateAndGet(started, (n) => n + 1),
          Effect.flatMap((count) =>
            pipe(
              Deferred.succeed(trigger, void 0),
              Effect.when(() => count === 3),
              Effect.zipRight(Deferred.await(trigger)),
              Effect.zipRight(Effect.fail(n))
            )
          )
        )
      }
      const started = yield* (Ref.make(0))
      const trigger = yield* (Deferred.make<void>())
      const result = yield* pipe(