Function release

packages/effect/src/internal/rcMap.ts:195–237

(self: RcMapImpl<K, A, E>, key: K, entry: State.Entry<A, E>)

})

const release = <K, A, E>(self: RcMapImpl<K, A, E>, key: K, entry: State.Entry<A, E>) =>
  coreEffect.clockWith((clock) => {
    entry.refCount--
    if (entry.refCount > 0) {
      return core.void
    } else if (
      self.state._tag === "Closed"
      || !MutableHashMap.has(self.state.map, key)
      || Duration.isZero(entry.idleTimeToLive)
    ) {
      if (self.state._tag === "Open") {
        MutableHashMap.remove(self.state.map, key)
      }
      return core.scopeClose(entry.scope, core.exitVoid)
    }

    if (!Duration.isFinite(entry.idleTimeToLive)) {
      return core.void
    }

    entry.expiresAt = clock.unsafeCurrentTimeMillis() + Duration.toMillis(entry.idleTimeToLive)
    if (entry.fiber) return core.void

    return core.interruptibleMask(function loop(restore): Effect<void> {
      const now = clock.unsafeCurrentTimeMillis()
      const remaining = entry.expiresAt - now
      if (remaining <= 0) {
        if (self.state._tag === "Closed" || entry.refCount > 0) return core.void
        MutableHashMap.remove(self.state.map, key)
        return restore(core.scopeClose(entry.scope, core.exitVoid))
      }
      return core.flatMap(clock.sleep(Duration.millis(remaining)), () => loop(restore))
    }).pipe(
      fiberRuntime.ensuring(core.sync(() => {
        entry.fiber = undefined
      })),
      circular.forkIn(self.scope),
      core.tap((fiber) => {
        entry.fiber = fiber
      }),
      self.semaphore.withPermits(1)
    )
  })

/** @internal */
export const keys = <K, A, E>(self: RcMap.RcMap<K, A, E>): Effect<Array<K>> => {