Class CounterImpl

packages/effect/test/utils/counter.ts:14–47

}

class CounterImpl implements Counter {
  constructor(readonly ref: Ref.Ref<readonly [number, number]>) {}

  acquire(): Effect.Effect<number, never, Scope.Scope> {
    return pipe(
      this.incrementAcquire(),
      Effect.zipRight(Effect.addFinalizer(() => this.incrementRelease())),
      Effect.zipRight(this.acquired()),
      Effect.uninterruptible
    )
  }

  incrementAcquire(): Effect.Effect<number> {
    return Ref.modify(this.ref, ([acquire, release]) => [acquire + 1, [acquire + 1, release] as const] as const)
  }

  incrementRelease(): Effect.Effect<number> {
    return Ref.modify(this.ref, ([acquire, release]) => [release + 1, [acquire, release + 1] as const] as const)
  }

  acquired(): Effect.Effect<number> {
    return pipe(
      Ref.get(this.ref),
      Effect.map((tuple) => tuple[0])
    )
  }

  released(): Effect.Effect<number> {
    return pipe(
      Ref.get(this.ref),
      Effect.map((tuple) => tuple[1])
    )
  }
}

export const make = (): Effect.Effect<Counter> => {
  return pipe(