(exit: Exit<void, E>)
| 451 | } |
| 452 | |
| 453 | private finalize(exit: Exit<void, E>) { |
| 454 | if (this.state._tag === "Done") { |
| 455 | return |
| 456 | } |
| 457 | const openState = this.state |
| 458 | this.state = { _tag: "Done", exit } |
| 459 | for (const taker of openState.takers) { |
| 460 | taker(exit) |
| 461 | } |
| 462 | openState.takers.clear() |
| 463 | for (const awaiter of openState.awaiters) { |
| 464 | awaiter(exit) |
| 465 | } |
| 466 | openState.awaiters.clear() |
| 467 | } |
| 468 | } |
| 469 | |
| 470 | /** @internal */ |
no test coverage detected