Function plus1

packages/effect/test/Effect/concurrency.test.ts:87–93

(latch: Deferred.Deferred<void, never>, finalizer: Effect.Effect<X>)

  it.effect("daemon fiber race interruption", () =>
    Effect.gen(function*() {
      const plus1 = <X>(latch: Deferred.Deferred<void, never>, finalizer: Effect.Effect<X>) => {
        return pipe(
          Deferred.succeed(latch, void 0),
          Effect.zipRight(Effect.sleep(Duration.hours(1))),
          Effect.onInterrupt(() => pipe(finalizer, Effect.map((x) => x)))
        )
      }
      const interruptionRef = yield* (Ref.make(0))
      const latch1Start = yield* (Deferred.make<void>())
      const latch2Start = yield* (Deferred.make<void>())