Function withLatch

packages/effect/test/utils/latch.ts:6–15

(
  f: (release: Effect.Effect<void>) => Effect.Effect<A, E, R>
)

import * as Ref from "effect/Ref"

export const withLatch = <A, E, R>(
  f: (release: Effect.Effect<void>) => Effect.Effect<A, E, R>
): Effect.Effect<A, E, R> => {
  return pipe(
    Deferred.make<void>(),
    Effect.flatMap((latch) =>
      pipe(f(pipe(Deferred.succeed(latch, void 0), Effect.asVoid)), Effect.zipLeft(Deferred.await(latch)))
    )
  )
}

export const withLatchAwait = <A, E, R>(
  f: (release: Effect.Effect<void>, wait: Effect.Effect<void>) => Effect.Effect<A, E, R>