Function modifyWithPermitWithEffect

packages/effect-app/src/Effect.ts:103–114

(ref: Ref.Ref<A>, semaphore: Semaphore)

 * Ref has atomic modify support if synchronous, for Effect we need a Semaphore.
 */
export function modifyWithPermitWithEffect<A>(ref: Ref.Ref<A>, semaphore: Semaphore) {
  const withPermit = semaphore.withPermits(1)
  return <R, E, A2>(mod: (a: A) => Effect.Effect<readonly [A2, A], E, R>) =>
    withPermit(
      Effect
        .flatMap(Ref.get(ref), mod)
        .pipe(
          Effect.tap(([, _]) => Ref.set(ref, _)),
          Effect.map(([_]) => _)
        )
    )
}

type ServiceA<T> = T extends Effect.Effect<infer S, any, any> ? S
  : T extends Context.Service<any, infer S> ? S