(poolItem: PoolItem<A, E>)
| 296 | } |
| 297 | |
| 298 | invalidatePoolItem(poolItem: PoolItem<A, E>): Effect<void> { |
| 299 | return core.suspend(() => { |
| 300 | if (!this.items.has(poolItem)) { |
| 301 | return core.void |
| 302 | } else if (poolItem.refCount === 0) { |
| 303 | this.items.delete(poolItem) |
| 304 | this.available.delete(poolItem) |
| 305 | this.invalidated.delete(poolItem) |
| 306 | return core.zipRight( |
| 307 | poolItem.finalizer, |
| 308 | circular.forkIn(core.interruptible(this.resize), this.scope) |
| 309 | ) |
| 310 | } |
| 311 | this.invalidated.add(poolItem) |
| 312 | this.available.delete(poolItem) |
| 313 | return core.void |
| 314 | }) |
| 315 | } |
| 316 | |
| 317 | get shutdown(): Effect<void> { |
| 318 | return core.suspend(() => { |
no test coverage detected