(fiber: Fiber<any, any>, n: number)
| 255 | } |
| 256 | |
| 257 | releaseUnsafe(fiber: Fiber<any, any>, n: number): number { |
| 258 | this.taken -= n |
| 259 | if (this.waiters.size > 0) { |
| 260 | fiber.currentDispatcher.scheduleTask(() => { |
| 261 | for (const observer of this.waiters) { |
| 262 | if (this.free <= 0) break |
| 263 | observer() |
| 264 | } |
| 265 | }, 0) |
| 266 | } |
| 267 | return this.free |
| 268 | } |
| 269 | |
| 270 | resize(permits: number) { |
| 271 | return core.withFiber((fiber) => { |
no test coverage detected