account for invalidated in usage strategy

Effect-TS · May 28, 2024 · 819f837 · 819f837
1 parent 700bc04
commit 819f837
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/packages/effect/src/internal/pool.ts b/packages/effect/src/internal/pool.ts
@@ -188,6 +188,7 @@ class PoolImpl<A, E> implements Pool<A, E> {
             return this.getPoolItem
           } else if (poolItem.exit._tag === "Failure") {
             this.items.delete(poolItem)
+            this.invalidated.delete(poolItem)
             return core.succeed(poolItem)
           }
           poolItem.refCount++
@@ -311,7 +312,7 @@ const strategyUsageTTL = <A, E>(ttl: Duration.DurationInput) =>
     return identity<Strategy<A, E>>({
       run: (pool) => {
         const process: Effect<void> = core.suspend(() => {
-          const excess = pool.items.size - pool.targetSize
+          const excess = pool.items.size - pool.invalidated.size - pool.targetSize
           if (excess <= 0) return core.void
           return queue.take.pipe(
             core.tap((item) => pool.invalidatePoolItem(item)),