Function makeEffect

packages/effect/test/utils/cache/ObservableResource.ts:47–71

(
  effect: Effect.Effect<V, E>
)

export const make = <V>(value: V): Effect.Effect<ObservableResource<never, V>> => makeEffect(Effect.succeed(value))

export const makeEffect = <V, E>(
  effect: Effect.Effect<V, E>
): Effect.Effect<ObservableResource<E, V>> =>
  pipe(
    Effect.zip(Ref.make(0), Ref.make(0)),
    Effect.map(([resourceAcquisitionCount, resourceAcquisitionReleasing]) => {
      const getState = Effect.zip(
        Ref.get(resourceAcquisitionCount),
        Ref.get(resourceAcquisitionReleasing)
      )
      const scoped = Effect.uninterruptibleMask((restore) =>
        Effect.gen(function*() {
          const parent = yield* Effect.scope
          const child = yield* Scope.fork(parent, ExecutionStrategy.sequential)
          yield* Ref.update(resourceAcquisitionCount, (n) => n + 1)
          yield* Scope.addFinalizer(child, Ref.update(resourceAcquisitionReleasing, (n) => n + 1))
          return yield* Effect.acquireReleaseInterruptible(
            restore(effect),
            (exit) => Scope.close(child, exit)
          )
        })
      )
      return new ObservableResourceImpl(scoped, getState)
    })
  )