(item: A)
| 283 | ) |
| 284 | |
| 285 | invalidate(item: A): Effect<void> { |
| 286 | return core.suspend(() => { |
| 287 | if (this.isShuttingDown) return core.void |
| 288 | for (const poolItem of this.items) { |
| 289 | if (poolItem.exit._tag === "Success" && poolItem.exit.value === item) { |
| 290 | poolItem.disableReclaim = true |
| 291 | return core.uninterruptible(this.invalidatePoolItem(poolItem)) |
| 292 | } |
| 293 | } |
| 294 | return core.void |
| 295 | }) |
| 296 | } |
| 297 | |
| 298 | invalidatePoolItem(poolItem: PoolItem<A, E>): Effect<void> { |
| 299 | return core.suspend(() => { |
nothing calls this directly
no test coverage detected